public static class FrameTask.ExtractDenseRow extends water.MRTask<FrameTask.ExtractDenseRow>
Modifier and Type | Field and Description |
---|---|
DataInfo.Row |
_row |
Constructor and Description |
---|
FrameTask.ExtractDenseRow(DataInfo di,
long globalRowId) |
Modifier and Type | Method and Description |
---|---|
void |
map(water.fvec.Chunk[] cs) |
void |
reduce(FrameTask.ExtractDenseRow mrt) |
appendables, asyncExecOnAllNodes, block, closeLocal, compute2, dfork, dfork, dfork, dfork, dfork, dinvoke, doAll, doAll, doAll, doAll, doAll, doAll, doAll, doAll, doAll, doAll, doAll, doAll, doAllNodes, getResult, getResult, isReleasable, map, map, map, map, map, map, map, map, map, map, modifiesVolatileVecs, onCompletion, onExceptionalCompletion, outputFrame, outputFrame, outputFrame, postGlobal, profile, profString, self, setupLocal
copyOver, getDException, hasException, logVerbose, onAck, onAckAck, setException
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, 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 DataInfo.Row _row
public FrameTask.ExtractDenseRow(DataInfo di, long globalRowId)
public void map(water.fvec.Chunk[] cs)
map
in class water.MRTask<FrameTask.ExtractDenseRow>
public void reduce(FrameTask.ExtractDenseRow mrt)
reduce
in class water.MRTask<FrameTask.ExtractDenseRow>