public class ProfileCollectorTask extends DRemoteTask<ProfileCollectorTask>
Modifier and Type | Class and Description |
---|---|
static class |
ProfileCollectorTask.NodeProfile |
Modifier and Type | Field and Description |
---|---|
ProfileCollectorTask.NodeProfile[] |
_result |
int |
_stack_depth |
_fs, _is_local, _keys, _top_level
_cls, _eFromNode, _exception, _fname, _lineNum, _msg, _mth
Constructor and Description |
---|
ProfileCollectorTask(int stack_depth) |
Modifier and Type | Method and Description |
---|---|
void |
lcompute() |
byte |
priority() |
void |
reduce(ProfileCollectorTask that) |
alsoBlockFor, alsoBlockFor, block, clone, compute2, dfork, getFutures, init, invoke, invokeOnAllNodes, isReleasable, keys, lonCompletion, onCompletion, postGlobal, reduceAlsoBlock
copyOver, dinvoke, frozenType, getDException, hasException, logVerbose, newInstance, onAck, onAckAck, onExceptionalCompletion, read, setException, toDocField, write, writeJSONFields
compute
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 ProfileCollectorTask.NodeProfile[] _result
public final int _stack_depth
public void reduce(ProfileCollectorTask that)
reduce
in class DRemoteTask<ProfileCollectorTask>
public void lcompute()
lcompute
in class DRemoteTask<ProfileCollectorTask>
public byte priority()
priority
in class H2O.H2OCountedCompleter