public static class GLMTask.CalculateW4Data extends water.MRTask<GLMTask.CalculateW4Data>
Modifier and Type | Field and Description |
---|---|
int |
_augZID |
double[] |
_beta |
int |
_dataColNumber |
DataInfo |
_dinfo |
int |
_etaOldID |
double |
_HL_correction |
int |
_numColStart |
int |
_numRandCol |
int |
_offsetID |
double[] |
_phi |
int |
_prior_weightID |
double[] |
_psi |
int[] |
_randCatLevels |
int[] |
_random_columnsID |
double |
_sumEtaDiffSq |
double |
_sumEtaSq |
double |
_tau |
double[] |
_ubeta |
int |
_wdataID |
Constructor and Description |
---|
CalculateW4Data(water.Job job,
DataInfo dInfo,
GLMModel.GLMParameters params,
int[] randCatLevels,
double[] beta,
double[] ubeta,
double[] psi,
double[] phi,
double tau,
double hlCorrection) |
Modifier and Type | Method and Description |
---|---|
void |
map(water.fvec.Chunk[] chunks) |
void |
reduce(GLMTask.CalculateW4Data other) |
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 int _prior_weightID
public int _wdataID
public int _offsetID
public int[] _random_columnsID
public int[] _randCatLevels
public int _augZID
public int _etaOldID
public int _dataColNumber
public int _numColStart
public double[] _beta
public double[] _ubeta
public double[] _psi
public double[] _phi
public double _tau
public int _numRandCol
public double _sumEtaDiffSq
public double _sumEtaSq
public double _HL_correction
public CalculateW4Data(water.Job job, DataInfo dInfo, GLMModel.GLMParameters params, int[] randCatLevels, double[] beta, double[] ubeta, double[] psi, double[] phi, double tau, double hlCorrection)
public void map(water.fvec.Chunk[] chunks)
map
in class water.MRTask<GLMTask.CalculateW4Data>
public void reduce(GLMTask.CalculateW4Data other)
reduce
in class water.MRTask<GLMTask.CalculateW4Data>