public static class VecUtils.CollectDomainFast extends MRTask<VecUtils.CollectDomainFast>
Vec
A map-reduce task to collect up the unique values of an integer Vec
and returned as the domain for the Vec
.MRTask.PostMapAction<T extends MRTask.PostMapAction<T>>
DTask.DKeyTask<T extends DTask.DKeyTask,V extends Keyed>, DTask.RemoveCall
Constructor and Description |
---|
CollectDomainFast(int s) |
Modifier and Type | Method and Description |
---|---|
long[] |
domain()
Returns exact numeric domain of given
Vec computed by this task. |
void |
map(Chunk ys)
Override with your map implementation.
|
protected void |
postGlobal() |
void |
reduce(VecUtils.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, 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, map, modifiesVolatileVecs, onCompletion, onExceptionalCompletion, outputFrame, outputFrame, outputFrame, profile, profString, self, withPostMapAction
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, 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<VecUtils.CollectDomainFast>
public void map(Chunk ys)
MRTask
map
in class MRTask<VecUtils.CollectDomainFast>
public void reduce(VecUtils.CollectDomainFast mrt)
MRTask
reduce
in class MRTask<VecUtils.CollectDomainFast>
protected void postGlobal()
postGlobal
in class MRTask<VecUtils.CollectDomainFast>
public long[] domain()
Vec
computed by this task.
The domain is always sorted. Hence:
domain()[0] - minimal domain value
domain()[domain().length-1] - maximal domain value