public static class GLMTask.RandColAddW2AugXZ extends water.MRTask<GLMTask.RandColAddW2AugXZ>
Modifier and Type | Field and Description |
---|---|
int[] |
_cumRandCatLevels |
int |
_randNumColStart |
long |
_randRowStart |
int |
_totAugxzColNumber |
int[] |
_weightID |
Constructor and Description |
---|
RandColAddW2AugXZ(water.Job job,
int[] randCatLevels,
water.fvec.Frame prior_weights_psi,
int wpsiID,
long randRowStart,
int randNumColStart,
int augXZColNum) |
Modifier and Type | Method and Description |
---|---|
static int |
findRandColIndex(int[] cumrandCatLevels,
long colIndex)
Given colIndex to the expanded random columns, this method will calculate which random column that colIndex
belongs to.
|
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 int[] _cumRandCatLevels
public int _randNumColStart
public long _randRowStart
public int _totAugxzColNumber
public int[] _weightID
public RandColAddW2AugXZ(water.Job job, int[] randCatLevels, water.fvec.Frame prior_weights_psi, int wpsiID, long randRowStart, int randNumColStart, int augXZColNum)
public static int findRandColIndex(int[] cumrandCatLevels, long colIndex)
cumrandCatLevels
- colIndex
- public void map(water.fvec.Chunk[] chunks)
map
in class water.MRTask<GLMTask.RandColAddW2AugXZ>