public static class AstStratifiedSplit.ClassIdxTask extends MRTask<AstStratifiedSplit.ClassIdxTask>
DTask.DKeyTask<T extends DTask.DKeyTask,V extends Keyed>, DTask.RemoveCall
Constructor and Description |
---|
AstStratifiedSplit.ClassIdxTask(int nclasses,
long[] classes) |
Modifier and Type | Method and Description |
---|---|
void |
map(Chunk[] ck)
Override with your map implementation.
|
void |
reduce(AstStratifiedSplit.ClassIdxTask c)
Override to combine results from 'mrt' into 'this' MRTask.
|
protected void |
setupLocal()
Override to do any remote initialization on the 1st remote instance of
this object, for initializing node-local shared data structures.
|
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, self
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 AstStratifiedSplit.ClassIdxTask(int nclasses, long[] classes)
protected void setupLocal()
MRTask
setupLocal
in class MRTask<AstStratifiedSplit.ClassIdxTask>
public void map(Chunk[] ck)
MRTask
map
in class MRTask<AstStratifiedSplit.ClassIdxTask>
public void reduce(AstStratifiedSplit.ClassIdxTask c)
MRTask
reduce
in class MRTask<AstStratifiedSplit.ClassIdxTask>