public static class FrameCreator.MissingInserter extends MRTask2<FrameCreator.MissingInserter>
DTask.DKeyTask<T extends DTask.DKeyTask,V extends Iced>
Constructor and Description |
---|
FrameCreator.MissingInserter(H2O.H2OCountedCompleter cmp,
long seed,
double frac) |
FrameCreator.MissingInserter(long seed,
double frac) |
Modifier and Type | Method and Description |
---|---|
void |
map(Chunk[] cs)
Override with your map implementation.
|
asyncExec, asyncExec, asyncExec, block, clone, closeLocal, compute2, dfork, dfork, dfork, dfork, dinvoke, doAll, doAll, doAll, doAll, doAll, doAll, exec, exec, exec, getResult, isReleasable, map, map, map, map, map, map, map, map, map, map, map, onCompletion, onExceptionalCompletion, outputFrame, outputFrame, outputFrame, postGlobal, priority, profString, reduce, reduce4, setupLocal, vecs
copyOver, frozenType, getDException, hasException, logVerbose, newInstance, onAck, onAckAck, read, setException, toDocField, write, writeJSONFields
compute
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 FrameCreator.MissingInserter(long seed, double frac)
public FrameCreator.MissingInserter(H2O.H2OCountedCompleter cmp, long seed, double frac)
public void map(Chunk[] cs)
MRTask2
map
in class MRTask2<FrameCreator.MissingInserter>