hex.hglm

Class HGLMTask.ComputationEngineTask

java.lang.Object

jsr166y.ForkJoinTask<java.lang.Void>

jsr166y.CountedCompleter

water.H2O.H2OCountedCompleter<T>

water.DTask<T>

water.MRTask<HGLMTask.ComputationEngineTask>

hex.hglm.HGLMTask.ComputationEngineTask

All Implemented Interfaces:

java.io.Serializable, java.lang.Cloneable, java.util.concurrent.Future<java.lang.Void>, jsr166y.ForkJoinPool.ManagedBlocker, water.Freezable<HGLMTask.ComputationEngineTask>

Enclosing class:

HGLMTask

public static class HGLMTask.ComputationEngineTask
extends water.MRTask<HGLMTask.ComputationEngineTask>

This class will pre-calculate arrays (double[]) or matrices (double[][]) that will be used in later calculations that are part of the CDSS described in equation 11 of the doc.

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from class water.MRTask

water.MRTask.PostMapAction<T extends water.MRTask.PostMapAction<T>>

Nested classes/interfaces inherited from class water.DTask

water.DTask.DKeyTask<T extends water.DTask.DKeyTask,V extends water.Keyed>, water.DTask.RemoveCall

Field Summary

Fields

Modifier and Type	Field and Description
double[][][]	_AfjTAfj
double[][][]	_AfjTArj
double[][]	_AfjTYj
double[]	_AfjTYjSum
double[][]	_AfTAftInv
double[]	_AfTAftInvAfjTYj
double[][][]	_ArjTAfj
double[][][]	_ArjTArj
double[][]	_ArjTYj

Fields inherited from class water.MRTask

_appendables, _fr, _fs, _hi, _keys, _left, _lo, _nhi, _nleft, _nlo, _nrite, _rite, _run_local, _topLocal

Fields inherited from class water.DTask

_ex

Constructor Summary

Constructors

Constructor and Description
ComputationEngineTask(water.Job job, HGLMModel.HGLMParameters parms, DataInfo dinfo)

Method Summary

Modifier and Type	Method and Description
static void	fillInFixedRowValues(DataInfo.Row r, double[] xji, HGLMModel.HGLMParameters parms, int[] fixedCatIndices, int level2UnitIndex, int numLevel2Units, int predStartIndexFixed, DataInfo dinfo)
static hex.hglm.HGLMTask.ComputationEngineTask.RowInfo	grabCatIndexVal(DataInfo.Row r, int startEnumInd, int enumIndexOfInterest, DataInfo dinfo)
void	map(water.fvec.Chunk[] chks)
void	postGlobal()
void	reduce(HGLMTask.ComputationEngineTask otherTask)
static void	sumAfjAfjAfjTYj(double[][][] afjTAfj, double[][] afjTYj, double[][] sumAfjAfj, double[] sumAfjTYj)

Methods inherited from class water.MRTask

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, profile, profString, self, setupLocal, withPostMapAction

Methods inherited from class water.DTask

copyOver, getDException, hasException, logVerbose, onAck, onAckAck, setException

Methods inherited from class water.H2O.H2OCountedCompleter

asBytes, clone, compute, compute1, currThrPriority, frozenType, icer, priority, read, readJSON, reloadFromBytes, write, writeJSON

Methods inherited from class jsr166y.CountedCompleter

__tryComplete, addToPendingCount, compareAndSetPendingCount, complete, exec, getCompleter, getPendingCount, getRawResult, setCompleter, setPendingCount, setRawResult, tryComplete

Methods inherited from class jsr166y.ForkJoinTask

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

Methods inherited from class java.lang.Object

equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

_AfjTYj

public double[][] _AfjTYj

_ArjTYj

public double[][] _ArjTYj

_AfjTAfj

public double[][][] _AfjTAfj

_ArjTArj

public double[][][] _ArjTArj

_AfjTArj

public double[][][] _AfjTArj

_ArjTAfj

public double[][][] _ArjTAfj

_AfTAftInv

public double[][] _AfTAftInv

_AfTAftInvAfjTYj

public double[] _AfTAftInvAfjTYj

_AfjTYjSum

public double[] _AfjTYjSum

Constructor Detail

ComputationEngineTask

public ComputationEngineTask(water.Job job,
                             HGLMModel.HGLMParameters parms,
                             DataInfo dinfo)

Method Detail

map

public void map(water.fvec.Chunk[] chks)

Overrides:

map in class water.MRTask<HGLMTask.ComputationEngineTask>

fillInFixedRowValues

public static void fillInFixedRowValues(DataInfo.Row r,
                                        double[] xji,
                                        HGLMModel.HGLMParameters parms,
                                        int[] fixedCatIndices,
                                        int level2UnitIndex,
                                        int numLevel2Units,
                                        int predStartIndexFixed,
                                        DataInfo dinfo)

grabCatIndexVal

public static hex.hglm.HGLMTask.ComputationEngineTask.RowInfo grabCatIndexVal(DataInfo.Row r,
                                                                              int startEnumInd,
                                                                              int enumIndexOfInterest,
                                                                              DataInfo dinfo)

reduce

public void reduce(HGLMTask.ComputationEngineTask otherTask)

Overrides:

reduce in class water.MRTask<HGLMTask.ComputationEngineTask>

postGlobal

public void postGlobal()

Overrides:

postGlobal in class water.MRTask<HGLMTask.ComputationEngineTask>

sumAfjAfjAfjTYj

public static void sumAfjAfjAfjTYj(double[][][] afjTAfj,
                                   double[][] afjTYj,
                                   double[][] sumAfjAfj,
                                   double[] sumAfjTYj)