public abstract class FrameTask2<T extends FrameTask2<T>>
extends water.MRTask<T>
Modifier and Type | Field and Description |
---|---|
protected DataInfo |
_dinfo |
water.fvec.Vec |
_rowFilter |
protected boolean |
_sparse |
Constructor and Description |
---|
FrameTask2(water.H2O.H2OCountedCompleter cmp,
DataInfo dinfo,
water.Key jobKey) |
FrameTask2(water.H2O.H2OCountedCompleter cmp,
DataInfo dinfo,
water.Key jobKey,
water.fvec.Vec rowFilter) |
Modifier and Type | Method and Description |
---|---|
void |
chunkDone()
Perform action after processing one "chunk" of data/
|
void |
chunkInit()
Initialization method, called once per "chunk".
|
boolean |
handlesSparseData() |
void |
map(water.fvec.Chunk[] chks) |
protected abstract void |
processRow(DataInfo.Row r) |
T |
setSparse(boolean b) |
double |
sparseOffset() |
appendables, asyncExec, asyncExec, asyncExec, block, closeLocal, compute2, dfork, dfork, dfork, dfork, dinvoke, doAll, doAll, doAll, doAll, doAll, doAll, doAll, doAll, doAll, doAllNodes, getResult, isReleasable, map, map, map, map, map, map, map, map, map, map, map, map, onCompletion, onExceptionalCompletion, outputFrame, outputFrame, outputFrame, postGlobal, postLocal, priority, profString, reduce, self, setProfile, setupLocal
copyOver, getDException, hasException, logVerbose, onAck, onAckAck, setException
clone, compute, frozenType, icer, nextThrPriority, 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
protected boolean _sparse
public final water.fvec.Vec _rowFilter
protected final DataInfo _dinfo
public FrameTask2(water.H2O.H2OCountedCompleter cmp, DataInfo dinfo, water.Key jobKey)
public FrameTask2(water.H2O.H2OCountedCompleter cmp, DataInfo dinfo, water.Key jobKey, water.fvec.Vec rowFilter)
public T setSparse(boolean b)
public void chunkInit()
public void chunkDone()
public double sparseOffset()
public boolean handlesSparseData()
protected abstract void processRow(DataInfo.Row r)
public void map(water.fvec.Chunk[] chks)
map
in class water.MRTask<T extends FrameTask2<T>>