public static class Vec.CollectDomainFast extends MRTask<Vec.CollectDomainFast>
DTask.DKeyTask<T extends DTask.DKeyTask,V extends Keyed>, DTask.RemoveCall
_appendables, _fr, _fs, _hi, _keys, _left, _lo, _nhi, _nleft, _nrite, _nxx, _rite, _topLocal
_ex, _modifiesInputs
Modifier and Type | Method and Description |
---|---|
long[] |
domain()
Returns exact numeric domain of given vector computed by this task.
|
void |
map(Chunk ys)
Override with your map implementation.
|
protected void |
postGlobal() |
void |
reduce(Vec.CollectDomainFast mrt)
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, asyncExec, asyncExec, asyncExec, block, closeLocal, compute2, dfork, dfork, dfork, dfork, dinvoke, doAll, doAll, doAll, doAll, doAll, doAll, doAll, doAllNodes, getResult, isReleasable, map, map, map, map, map, map, map, map, map, map, map, map, onCompletion, onExceptionalCompletion, outputFrame, outputFrame, outputFrame, outputFrame, priority, profString, setProfile
copyOver, getDException, hasException, logVerbose, onAck, onAckAck, setException
clone, compute, frozenType, icer, nextThrPriority, read_impl, read, readJSON_impl, readJSON, write_impl, write, writeHTML_impl, writeHTML, writeJSON_impl, writeJSON
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
protected void setupLocal()
MRTask
setupLocal
in class MRTask<Vec.CollectDomainFast>
public void map(Chunk ys)
MRTask
map
in class MRTask<Vec.CollectDomainFast>
public void reduce(Vec.CollectDomainFast mrt)
MRTask
reduce
in class MRTask<Vec.CollectDomainFast>
protected void postGlobal()
postGlobal
in class MRTask<Vec.CollectDomainFast>
public long[] domain()