public class ProfileCollectorTask extends MRTask<ProfileCollectorTask>
Modifier and Type | Class and Description |
---|---|
static class |
ProfileCollectorTask.NodeProfile |
DTask.DKeyTask<T extends DTask.DKeyTask,V extends Keyed>, DTask.RemoveCall
Modifier and Type | Field and Description |
---|---|
ProfileCollectorTask.NodeProfile[] |
_result |
int |
_stack_depth |
Constructor and Description |
---|
ProfileCollectorTask(int stack_depth) |
Modifier and Type | Method and Description |
---|---|
void |
reduce(ProfileCollectorTask that)
Override to combine results from 'mrt' into 'this' MRTask.
|
void |
setupLocal()
This runs on each node in the cluster.
|
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
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 final int _stack_depth
public ProfileCollectorTask.NodeProfile[] _result
public void reduce(ProfileCollectorTask that)
MRTask
reduce
in class MRTask<ProfileCollectorTask>
public void setupLocal()
setupLocal
in class MRTask<ProfileCollectorTask>