public static class GLMTask.ReturnGLMMMERunInfoRandCols extends water.MRTask<GLMTask.ReturnGLMMMERunInfoRandCols>
Modifier and Type | Field and Description |
---|---|
int[] |
_cumRandCatLevels |
DataInfo |
_dinfo |
long |
_numDataRow |
int |
_numRandCol |
double[] |
_psi |
water.fvec.Frame |
_qMatrix |
int |
_totalqMatrixCols |
double[] |
_ubeta |
water.fvec.Frame |
_w_prior_wpsi |
int[] |
_wpriorwpsiCol |
Constructor and Description |
---|
ReturnGLMMMERunInfoRandCols(water.Job job,
DataInfo datainfo,
water.fvec.Frame wpriorwpsi,
water.fvec.Frame qmatrix,
int[] wCol,
GLMModel.GLMParameters params,
double[] psi,
double[] ubeta,
int[] cumRandCatLevels) |
Modifier and Type | Method and Description |
---|---|
static GLMModel.GLMWeightsFun[] |
getRandGLMFuns(GLMModel.GLMWeightsFun[] randGLMs,
int numRandFuncs,
GLMModel.GLMParameters params) |
void |
map(water.fvec.Chunk[] chunks) |
void |
reduce(GLMTask.ReturnGLMMMERunInfoRandCols other) |
static void |
setHv(water.fvec.Chunk[] qmat,
water.fvec.Chunk hv,
int relRowIndex,
int qmatRelRowIndex) |
static double |
setZDevEta(water.fvec.Chunk[] wpsiChunks,
water.fvec.Chunk[] destChunk,
int relRowIndex,
int wpsiRowIndex,
int abswpsiRowIndex,
double[] psi,
double[] ubeta) |
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, 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 water.fvec.Frame _w_prior_wpsi
public water.fvec.Frame _qMatrix
public int _totalqMatrixCols
public int[] _wpriorwpsiCol
public long _numDataRow
public double[] _psi
public double[] _ubeta
public int[] _cumRandCatLevels
public int _numRandCol
public ReturnGLMMMERunInfoRandCols(water.Job job, DataInfo datainfo, water.fvec.Frame wpriorwpsi, water.fvec.Frame qmatrix, int[] wCol, GLMModel.GLMParameters params, double[] psi, double[] ubeta, int[] cumRandCatLevels)
public void map(water.fvec.Chunk[] chunks)
map
in class water.MRTask<GLMTask.ReturnGLMMMERunInfoRandCols>
public static GLMModel.GLMWeightsFun[] getRandGLMFuns(GLMModel.GLMWeightsFun[] randGLMs, int numRandFuncs, GLMModel.GLMParameters params)
public void reduce(GLMTask.ReturnGLMMMERunInfoRandCols other)
reduce
in class water.MRTask<GLMTask.ReturnGLMMMERunInfoRandCols>
public static void setHv(water.fvec.Chunk[] qmat, water.fvec.Chunk hv, int relRowIndex, int qmatRelRowIndex)
public static double setZDevEta(water.fvec.Chunk[] wpsiChunks, water.fvec.Chunk[] destChunk, int relRowIndex, int wpsiRowIndex, int abswpsiRowIndex, double[] psi, double[] ubeta)