public static class GLMTask.CalculateAugZWRandCols extends water.MRTask<GLMTask.CalculateAugZWRandCols>
Modifier and Type | Field and Description |
---|---|
long |
_numDataRows |
int[] |
_weightWCol |
Constructor and Description |
---|
CalculateAugZWRandCols(water.Job job,
water.fvec.Frame prior_weight_psi,
int weightColStart,
long numDataRows) |
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 CalculateAugZWRandCols(water.Job job, water.fvec.Frame prior_weight_psi, int weightColStart, long numDataRows)
public void map(water.fvec.Chunk[] chunks)
map
in class water.MRTask<GLMTask.CalculateAugZWRandCols>