public static class MRUtils.ParallelTasks<T extends DTask<T>> extends H2O.H2OCountedCompleter
Modifier and Type | Field and Description |
---|---|
int |
_maxP |
T[] |
_tasks |
_priority
Constructor and Description |
---|
MRUtils.ParallelTasks(H2O.H2OCountedCompleter cmp,
T[] tsks) |
MRUtils.ParallelTasks(H2O.H2OCountedCompleter cmp,
T[] tsks,
int maxP) |
Modifier and Type | Method and Description |
---|---|
void |
compute2()
Override to specify actual work to do
|
clone, compute, frozenType, icer, nextThrPriority, onExceptionalCompletion, priority, read_impl, read, readJSON_impl, readJSON, write_impl, write, writeJSON_impl, writeJSON
__tryComplete, addToPendingCount, compareAndSetPendingCount, complete, exec, getCompleter, getPendingCount, getRawResult, onCompletion, 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 MRUtils.ParallelTasks(H2O.H2OCountedCompleter cmp, T[] tsks)
public MRUtils.ParallelTasks(H2O.H2OCountedCompleter cmp, T[] tsks, int maxP)
public void compute2()
H2O.H2OCountedCompleter
compute2
in class H2O.H2OCountedCompleter