public static class GLMTask.CalculateAugZWData extends water.MRTask<GLMTask.CalculateAugZWData>
Modifier and Type | Field and Description |
---|---|
DataInfo |
_dinfo |
int[] |
_dinfoWCol |
long |
_numDataRows |
Constructor and Description |
---|
CalculateAugZWData(water.Job job,
DataInfo dInfo,
int dinfoRespColStart) |
Modifier and Type | Method and Description |
---|---|
void |
map(water.fvec.Chunk[] chunks) |
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, map, modifiesVolatileVecs, onCompletion, onExceptionalCompletion, outputFrame, outputFrame, outputFrame, postGlobal, profile, profString, reduce, self, setupLocal, withPostMapAction
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, 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 _dinfo
public long _numDataRows
public int[] _dinfoWCol
public CalculateAugZWData(water.Job job, DataInfo dInfo, int dinfoRespColStart)
public void map(water.fvec.Chunk[] chunks)
map
in class water.MRTask<GLMTask.CalculateAugZWData>