public static class GLMTask.CalculateW4Rand extends water.MRTask<GLMTask.CalculateW4Rand>
Modifier and Type | Field and Description |
---|---|
int[] |
_cumRandCatLevels |
int |
_numRandCol |
double[] |
_phi |
double[] |
_psi |
Constructor and Description |
---|
CalculateW4Rand(water.Job job,
GLMModel.GLMParameters params,
int[] randCatLevels,
double[] psi,
double[] phi,
double[] vi) |
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 double[] _psi
public double[] _phi
public int _numRandCol
public CalculateW4Rand(water.Job job, GLMModel.GLMParameters params, int[] randCatLevels, double[] psi, double[] phi, double[] vi)
public static int findRandColIndex(int[] cumrandCatLevels, long colIndex)
cumrandCatLevels
- colIndex
- public void map(water.fvec.Chunk[] chunks)
map
in class water.MRTask<GLMTask.CalculateW4Rand>