public static class RebalanceDataSet.RebalanceTask extends MRTask<RebalanceDataSet.RebalanceTask>
DTask.DKeyTask<T extends DTask.DKeyTask,V extends Keyed>, DTask.RemoveCall
Constructor and Description |
---|
RebalanceDataSet.RebalanceTask(H2O.H2OCountedCompleter cmp,
Vec... srcVecs) |
Modifier and Type | Method and Description |
---|---|
boolean |
logVerbose()
Override to remove 2 lines of logging per RPC.
|
void |
map(Chunk[] chks)
Override with your map implementation.
|
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, 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 RebalanceDataSet.RebalanceTask(H2O.H2OCountedCompleter cmp, Vec... srcVecs)
public boolean logVerbose()
DTask
logVerbose
in class DTask<RebalanceDataSet.RebalanceTask>
public void map(Chunk[] chks)
MRTask
map
in class MRTask<RebalanceDataSet.RebalanceTask>