public static class VecUtils.CollectDoubleDomain extends MRTask<VecUtils.CollectDoubleDomain>
DTask.DKeyTask<T extends DTask.DKeyTask,V extends Keyed>, DTask.RemoveCall
Constructor and Description |
---|
CollectDoubleDomain(double[] knownDomain,
int maxDomainSize) |
Modifier and Type | Method and Description |
---|---|
double[] |
domain() |
void |
map(Chunk ys)
Override with your map implementation.
|
protected void |
onMaxDomainExceeded(int maxDomainSize,
int currentSize) |
void |
reduce(VecUtils.CollectDoubleDomain mrt)
Override to combine results from 'mrt' into 'this' MRTask.
|
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 CollectDoubleDomain(double[] knownDomain, int maxDomainSize)
public void setupLocal()
MRTask
setupLocal
in class MRTask<VecUtils.CollectDoubleDomain>
public double[] domain()
public void map(Chunk ys)
MRTask
map
in class MRTask<VecUtils.CollectDoubleDomain>
public void reduce(VecUtils.CollectDoubleDomain mrt)
MRTask
reduce
in class MRTask<VecUtils.CollectDoubleDomain>
protected void onMaxDomainExceeded(int maxDomainSize, int currentSize)