public static class TreeMeasuresCollector.ShuffleTask extends water.MRTask<TreeMeasuresCollector.ShuffleTask>
Constructor and Description |
---|
TreeMeasuresCollector.ShuffleTask() |
Modifier and Type | Method and Description |
---|---|
void |
map(water.fvec.Chunk ic,
water.fvec.Chunk oc) |
static long |
seed(int cidx) |
static water.fvec.Vec |
shuffle(water.fvec.Vec ivec) |
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, modifiesVolatileVecs, onCompletion, onExceptionalCompletion, outputFrame, outputFrame, outputFrame, postGlobal, profile, profString, reduce, 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 void map(water.fvec.Chunk ic, water.fvec.Chunk oc)
map
in class water.MRTask<TreeMeasuresCollector.ShuffleTask>
public static long seed(int cidx)
public static water.fvec.Vec shuffle(water.fvec.Vec ivec)