public static class VecUtils.CollectIntegerDomain extends MRTask<VecUtils.CollectIntegerDomain>
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 |
---|
CollectIntegerDomain() |
Modifier and Type | Method and Description |
---|---|
void |
copyOver(VecUtils.CollectIntegerDomain that) |
long[] |
domain()
Returns exact numeric domain of given
Vec computed by this task. |
void |
map(Chunk ys)
Override with your map implementation.
|
VecUtils.CollectIntegerDomain |
read_impl(AutoBuffer ab) |
void |
reduce(VecUtils.CollectIntegerDomain 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.
|
AutoBuffer |
write_impl(AutoBuffer ab) |
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, postGlobal, profile, profString, self, withPostMapAction
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.CollectIntegerDomain>
public void map(Chunk ys)
MRTask
map
in class MRTask<VecUtils.CollectIntegerDomain>
public void reduce(VecUtils.CollectIntegerDomain mrt)
MRTask
reduce
in class MRTask<VecUtils.CollectIntegerDomain>
public final AutoBuffer write_impl(AutoBuffer ab)
public final VecUtils.CollectIntegerDomain read_impl(AutoBuffer ab)
public final void copyOver(VecUtils.CollectIntegerDomain that)
copyOver
in class DTask<VecUtils.CollectIntegerDomain>
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