public static class FrameUtils.ExportTaskDriver extends H2O.H2OCountedCompleter<FrameUtils.ExportTaskDriver>
Constructor and Description |
---|
ExportTaskDriver(Frame frame,
java.lang.String path,
java.lang.String frameName,
boolean overwrite,
Job j,
int nParts,
boolean perChunk,
CompressionFactory compressor,
Frame.CSVStreamParams csvParms) |
Modifier and Type | Method and Description |
---|---|
void |
compute2()
Override compute3() with actual work without having to worry about tryComplete()
|
void |
onCompletion(CountedCompleter caller)
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. |
boolean |
onExceptionalCompletion(java.lang.Throwable t,
CountedCompleter caller)
Performs an action when method
ForkJoinTask.completeExceptionally(java.lang.Throwable)
is invoked or method CountedCompleter.compute() throws an exception, and
this task has not otherwise already completed normally. |
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, 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 ExportTaskDriver(Frame frame, java.lang.String path, java.lang.String frameName, boolean overwrite, Job j, int nParts, boolean perChunk, CompressionFactory compressor, Frame.CSVStreamParams csvParms)
public void compute2()
H2O.H2OCountedCompleter
compute2
in class H2O.H2OCountedCompleter<FrameUtils.ExportTaskDriver>
public void onCompletion(CountedCompleter caller)
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
caller
- the task invoking this method (which may
be this task itself).public boolean onExceptionalCompletion(java.lang.Throwable t, CountedCompleter caller)
CountedCompleter
ForkJoinTask.completeExceptionally(java.lang.Throwable)
is invoked or method CountedCompleter.compute()
throws an exception, and
this task has not otherwise already completed normally. On
entry to this method, this task ForkJoinTask.isCompletedAbnormally()
. The return value of this
method controls further propagation: If true
and this
task has a completer, then this completer is also completed
exceptionally. The default implementation of this method does
nothing except return true
.onExceptionalCompletion
in class CountedCompleter
t
- the exceptioncaller
- the task invoking this method (which may
be this task itself).