public static class MRUtils.ClassDist extends MRTask<MRUtils.ClassDist>
DTask.DKeyTask<T extends DTask.DKeyTask,V extends Keyed>, DTask.RemoveCall
Modifier and Type | Field and Description |
---|---|
protected double[] |
_ys |
Modifier and Type | Method and Description |
---|---|
double[] |
dist() |
void |
map(Chunk ys)
Override with your map implementation.
|
void |
map(Chunk ys,
Chunk ws)
Override with your map implementation.
|
void |
reduce(MRUtils.ClassDist that)
Override to combine results from 'mrt' into 'this' MRTask.
|
double[] |
rel_dist() |
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, modifiesVolatileVecs, onCompletion, onExceptionalCompletion, outputFrame, outputFrame, outputFrame, postGlobal, profile, profString, self, setupLocal
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, 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 ClassDist(Vec label)
public ClassDist(int n)
public final double[] dist()
public final double[] rel_dist()
public void map(Chunk ys)
MRTask
map
in class MRTask<MRUtils.ClassDist>
public void map(Chunk ys, Chunk ws)
MRTask
map
in class MRTask<MRUtils.ClassDist>
public void reduce(MRUtils.ClassDist that)
MRTask
reduce
in class MRTask<MRUtils.ClassDist>