public static class Vec.CollectDomain extends MRTask<Vec.CollectDomain>
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
Constructor and Description |
---|
Vec.CollectDomain() |
Modifier and Type | Method and Description |
---|---|
void |
copyOver(Vec.CollectDomain that) |
long[] |
domain()
Returns exact numeric domain of given vector computed by this task.
|
void |
map(Chunk ys)
Override with your map implementation.
|
Vec.CollectDomain |
read_impl(AutoBuffer ab)
Implementation of the
Iced serialization protocol, only called by
auto-genned code. |
void |
reduce(Vec.CollectDomain 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)
Implementation of the
Iced serialization protocol, only called by
auto-genned code. |
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, postGlobal, priority, profString, setProfile
getDException, hasException, logVerbose, onAck, onAckAck, setException
clone, compute, frozenType, icer, nextThrPriority, read, readJSON_impl, readJSON, 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.CollectDomain>
public void map(Chunk ys)
MRTask
map
in class MRTask<Vec.CollectDomain>
public void reduce(Vec.CollectDomain mrt)
MRTask
reduce
in class MRTask<Vec.CollectDomain>
public AutoBuffer write_impl(AutoBuffer ab)
Freezable
Iced
serialization protocol, only called by
auto-genned code. Not intended to be called by user code. Override only
for custom Iced serializers.write_impl
in interface Freezable
write_impl
in class H2O.H2OCountedCompleter<Vec.CollectDomain>
ab
- AutoBuffer
to write this object to.AutoBuffer
for flow-coding.public Vec.CollectDomain read_impl(AutoBuffer ab)
Freezable
Iced
serialization protocol, only called by
auto-genned code. Not intended to be called by user code. Override only
for custom Iced serializers.read_impl
in interface Freezable
read_impl
in class H2O.H2OCountedCompleter<Vec.CollectDomain>
ab
- AutoBuffer
to read this object from.public void copyOver(Vec.CollectDomain that)
copyOver
in class DTask<Vec.CollectDomain>
public long[] domain()