public class FrameSplitter extends H2O.H2OCountedCompleter
The task creates ratios.length+1
output frame each containing a
demanded fraction of rows from source dataset
The tasks internally extract data from source chunks and create output chunks in preserving order of parts. I.e., the 1st partition contains the first P1-rows, the 2nd partition contains following P2-rows, ...
Assumptions and invariants
NOTE: the implementation is data-transfer expensive and in some cases it would be beneficial to use original implementation from 9af3f4e.
.Constructor and Description |
---|
FrameSplitter(Frame dataset,
double[] ratios,
Key[] destKeys,
Key jobKey) |
FrameSplitter(H2O.H2OCountedCompleter cc,
Frame dataset,
double[] ratios,
Key[] destKeys,
Key jobKey) |
Modifier and Type | Method and Description |
---|---|
void |
compute2()
Override to specify actual work to do
|
java.lang.Throwable[] |
getErrors() |
Frame[] |
getResult()
Blocking call to obtain a result of computation.
|
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. |
clone, compute, frozenType, icer, nextThrPriority, onExceptionalCompletion, 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 FrameSplitter(H2O.H2OCountedCompleter cc, Frame dataset, double[] ratios, Key[] destKeys, Key jobKey)
public void compute2()
H2O.H2OCountedCompleter
compute2
in class H2O.H2OCountedCompleter
public Frame[] getResult()
public java.lang.Throwable[] getErrors()
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).