public class RebalanceDataSet extends H2O.H2OCountedCompleter
Modifier and Type | Class and Description |
---|---|
static class |
RebalanceDataSet.RebalanceTask |
Constructor and Description |
---|
RebalanceDataSet(Frame modelFrame,
Frame srcFrame,
Key dstKey)
Constructor for make-compatible task.
|
RebalanceDataSet(Frame modelFrame,
Frame srcFrame,
Key dstKey,
H2O.H2OCountedCompleter cmp,
Key jobKey) |
RebalanceDataSet(Frame srcFrame,
Key dstKey,
int nchunks) |
RebalanceDataSet(Frame srcFrame,
Key dstKey,
int nchunks,
H2O.H2OCountedCompleter cmp,
Key jobKey) |
Modifier and Type | Method and Description |
---|---|
void |
compute2()
Override to specify actual work to do
|
Frame |
getResult() |
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)
Exceptional completion path; mostly does printing if the exception was
not handled earlier in the stack.
|
clone, compute, frozenType, icer, nextThrPriority, priority, read_impl, read, readJSON_impl, readJSON, write_impl, write, writeHTML_impl, writeHTML, writeJSON_impl, writeJSON
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 RebalanceDataSet(Frame modelFrame, Frame srcFrame, Key dstKey)
public RebalanceDataSet(Frame modelFrame, Frame srcFrame, Key dstKey, H2O.H2OCountedCompleter cmp, Key jobKey)
public RebalanceDataSet(Frame srcFrame, Key dstKey, int nchunks, H2O.H2OCountedCompleter cmp, Key jobKey)
public Frame getResult()
public void compute2()
H2O.H2OCountedCompleter
compute2
in class H2O.H2OCountedCompleter
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)
H2O.H2OCountedCompleter
onExceptionalCompletion
in class H2O.H2OCountedCompleter
t
- the exceptioncaller
- the task invoking this method (which may
be this task itself).