public static class VecUtils.MeanResponsePerLevelTask extends MRTask<VecUtils.MeanResponsePerLevelTask>
MRTask.PostMapAction<T extends MRTask.PostMapAction<T>>
DTask.DKeyTask<T extends DTask.DKeyTask,V extends Keyed>, DTask.RemoveCall
Modifier and Type | Field and Description |
---|---|
double |
meanOverallWeightedResponse |
double[] |
meanWeightedResponse |
Constructor and Description |
---|
MeanResponsePerLevelTask(int len) |
Modifier and Type | Method and Description |
---|---|
void |
map(Chunk c,
Chunk w,
Chunk r)
Override with your map implementation.
|
protected void |
postGlobal() |
void |
reduce(VecUtils.MeanResponsePerLevelTask mrt)
Override to combine results from 'mrt' into 'this' MRTask.
|
appendables, asyncExecOnAllNodes, block, closeLocal, compute2, dfork, dfork, dfork, dfork, dfork, dinvoke, doAll, doAll, doAll, doAll, doAll, doAll, doAll, doAll, doAll, doAll, doAll, doAll, doAllNodes, getResult, getResult, isReleasable, map, map, map, map, map, map, map, map, map, map, map, modifiesVolatileVecs, onCompletion, onExceptionalCompletion, outputFrame, outputFrame, outputFrame, profile, profString, self, setupLocal, withPostMapAction
copyOver, getDException, hasException, logVerbose, onAck, onAckAck, setException
asBytes, clone, compute, compute1, currThrPriority, frozenType, icer, priority, read, readJSON, reloadFromBytes, write, writeJSON
__tryComplete, addToPendingCount, compareAndSetPendingCount, complete, exec, getCompleter, getPendingCount, getRawResult, setCompleter, setPendingCount, setRawResult, tryComplete
adapt, adapt, adapt, cancel, compareAndSetForkJoinTaskTag, completeExceptionally, fork, get, get, get, getException, getForkJoinTaskTag, getPool, getQueuedTaskCount, getSurplusQueuedTaskCount, helpQuiesce, inForkJoinPool, invoke, invokeAll, invokeAll, invokeAll, isCancelled, isCompletedAbnormally, isCompletedNormally, isDone, join, peekNextLocalTask, pollNextLocalTask, pollTask, quietlyComplete, quietlyInvoke, quietlyJoin, reinitialize, setForkJoinTaskTag, tryUnfork
public double[] meanWeightedResponse
public double meanOverallWeightedResponse
public void map(Chunk c, Chunk w, Chunk r)
MRTask
map
in class MRTask<VecUtils.MeanResponsePerLevelTask>
public void reduce(VecUtils.MeanResponsePerLevelTask mrt)
MRTask
reduce
in class MRTask<VecUtils.MeanResponsePerLevelTask>
protected void postGlobal()
postGlobal
in class MRTask<VecUtils.MeanResponsePerLevelTask>