public class LocalMR<T extends MrFun<T>> extends H2O.H2OCountedCompleter<LocalMR>
Constructor and Description |
---|
LocalMR(MrFun mrt,
H2O.H2OCountedCompleter cc) |
LocalMR(MrFun mrt,
int nthreads) |
LocalMR(MrFun mrt,
int nthreads,
H2O.H2OCountedCompleter cc) |
Modifier and Type | Method and Description |
---|---|
void |
compute2()
Override compute3() with actual work without having to worry about tryComplete()
|
boolean |
isCancelRequested() |
boolean |
isReproducible() |
void |
onCompletion(CountedCompleter cc)
Performs an action when method
CountedCompleter.tryComplete() is invoked
and there are no pending counts, or when the unconditional
method CountedCompleter.complete(java.lang.Void) is invoked. |
LocalMR<T> |
withNoPrevTaskReuse() |
asBytes, clone, compute, compute1, currThrPriority, frozenType, icer, priority, read, readJSON, reloadFromBytes, write, writeJSON
__tryComplete, addToPendingCount, compareAndSetPendingCount, complete, exec, getCompleter, getPendingCount, getRawResult, onExceptionalCompletion, setCompleter, setPendingCount, setRawResult, tryComplete
adapt, adapt, adapt, cancel, compareAndSetForkJoinTaskTag, completeExceptionally, fork, get, 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 LocalMR(MrFun mrt, int nthreads)
public LocalMR(MrFun mrt, H2O.H2OCountedCompleter cc)
public LocalMR(MrFun mrt, int nthreads, H2O.H2OCountedCompleter cc)
public boolean isReproducible()
public boolean isCancelRequested()
public final void compute2()
H2O.H2OCountedCompleter
compute2
in class H2O.H2OCountedCompleter<LocalMR>
public final void onCompletion(CountedCompleter cc)
CountedCompleter
CountedCompleter.tryComplete()
is invoked
and there are no pending counts, or when the unconditional
method CountedCompleter.complete(java.lang.Void)
is invoked. By default, this method
does nothing.onCompletion
in class CountedCompleter
cc
- the task invoking this method (which may
be this task itself).