hex.glm

Class DispersionTask.ComputeMaxSumSeriesTsk

java.lang.Object

jsr166y.ForkJoinTask<java.lang.Void>

jsr166y.CountedCompleter

water.H2O.H2OCountedCompleter<T>

water.DTask<T>

water.MRTask<DispersionTask.ComputeMaxSumSeriesTsk>

hex.glm.DispersionTask.ComputeMaxSumSeriesTsk

All Implemented Interfaces:

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

Enclosing class:

DispersionTask

public static class DispersionTask.ComputeMaxSumSeriesTsk
extends water.MRTask<DispersionTask.ComputeMaxSumSeriesTsk>

This class will compute the following for every row of the dataset: 1. index of maximum magnitude of infinite series; 2. log(z) 3. W or V maximum 5. dW or dV maximum 6. d2W or d2V maximum 7. KL or JL for W or V 8. KU or JU for W or V 9. KL or JL for dW or dV 10. KU or JU for dW or dV 11. KL or JL for d2W or d2V 12. KU or JU for d2W or d2V 13. log likelihood 14. dlog likelihood / d phi 15. d2log likelihood / d2 phi

See Also:

Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static interface	DispersionTask.ComputeMaxSumSeriesTsk.CalWVdWVd2WV This interface is used to calculate one item of the series in log.
static class	DispersionTask.ComputeMaxSumSeriesTsk.EvalLogD2WVEnv
static class	DispersionTask.ComputeMaxSumSeriesTsk.EvalLogDWVEnv
static class	DispersionTask.ComputeMaxSumSeriesTsk.EvalLogWVEnv

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 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
ComputeMaxSumSeriesTsk(TweedieMLDispersionOnly tdispersion, GLMModel.GLMParameters parms, boolean calALL)

Method Summary

Modifier and Type	Method and Description
double	calLogWVMax(water.fvec.Chunk[] chks, int rowInd, int indexMax, double logZ)
double	calLogZ(water.fvec.Chunk[] chks, int rInd, int zConstCol)
int	estimateLowerBound(int jOrkMax, double logWorVmax, double logZ, DispersionTask.ComputeMaxSumSeriesTsk.CalWVdWVd2WV cVal)
int	estimateUpperBound(int jOrkMax, double logWorVmax, double logZ, int wvIndex, DispersionTask.ComputeMaxSumSeriesTsk.CalWVdWVd2WV cVal)
double	evalD2lldPhi2(water.fvec.Chunk[] chks, int rowInd, double sumDWVj, double sumD2WVj, double oneOverSumWVj, java.util.Map<DispersionTask.ConstColNames,java.lang.Integer> constColName2Ind)
double	evalDlldPhi(water.fvec.Chunk[] chks, int rowInd, double sumDWVj, double oneOverSumWVj, java.util.Map<DispersionTask.ConstColNames,java.lang.Integer> constColName2Ind)
double	evalLogLikelihood(water.fvec.Chunk[] chks, int rowInd, double sumWV, java.util.Map<DispersionTask.ConstColNames,java.lang.Integer> constColName2Ind)
int	findMaxTermIndex(water.fvec.Chunk[] chks, int rowInd, int colInd)
void	map(water.fvec.Chunk[] chks)
void	postGlobal()
void	reduce(DispersionTask.ComputeMaxSumSeriesTsk other)
static void	setConstIndices(java.util.Map<DispersionTask.ConstColNames,java.lang.Integer> constColName2Ind, int offset)
void	setDebugValues(int rInd, int jkIndMax, double logZ, double wvMax, double dwvMax, double d2wvMax, int jKL, int jKU, int djKL, int djKU, int d2jKL, int d2jKU, double sumWV, double sumDWV, double sumD2WV, double ll, double dll, double d2ll, water.fvec.Chunk[] chks, java.util.Map<DispersionTask.InfoColNames,java.lang.Integer> infoColName2Ind, double response)
static void	setInfoIndices(java.util.Map<DispersionTask.InfoColNames,java.lang.Integer> infoColName2Ind, int constOffset, boolean weightPresent)

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

Constructor Detail

ComputeMaxSumSeriesTsk

public ComputeMaxSumSeriesTsk(TweedieMLDispersionOnly tdispersion,
                              GLMModel.GLMParameters parms,
                              boolean calALL)

Method Detail

setInfoIndices

public static void setInfoIndices(java.util.Map<DispersionTask.InfoColNames,java.lang.Integer> infoColName2Ind,
                                  int constOffset,
                                  boolean weightPresent)

setConstIndices

public static void setConstIndices(java.util.Map<DispersionTask.ConstColNames,java.lang.Integer> constColName2Ind,
                                   int offset)

map

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

Overrides:

map in class water.MRTask<DispersionTask.ComputeMaxSumSeriesTsk>

setDebugValues

public void setDebugValues(int rInd,
                           int jkIndMax,
                           double logZ,
                           double wvMax,
                           double dwvMax,
                           double d2wvMax,
                           int jKL,
                           int jKU,
                           int djKL,
                           int djKU,
                           int d2jKL,
                           int d2jKU,
                           double sumWV,
                           double sumDWV,
                           double sumD2WV,
                           double ll,
                           double dll,
                           double d2ll,
                           water.fvec.Chunk[] chks,
                           java.util.Map<DispersionTask.InfoColNames,java.lang.Integer> infoColName2Ind,
                           double response)

reduce

public void reduce(DispersionTask.ComputeMaxSumSeriesTsk other)

Overrides:

reduce in class water.MRTask<DispersionTask.ComputeMaxSumSeriesTsk>

postGlobal

public void postGlobal()

Overrides:

postGlobal in class water.MRTask<DispersionTask.ComputeMaxSumSeriesTsk>

estimateLowerBound

public int estimateLowerBound(int jOrkMax,
                              double logWorVmax,
                              double logZ,
                              DispersionTask.ComputeMaxSumSeriesTsk.CalWVdWVd2WV cVal)

estimateUpperBound

public int estimateUpperBound(int jOrkMax,
                              double logWorVmax,
                              double logZ,
                              int wvIndex,
                              DispersionTask.ComputeMaxSumSeriesTsk.CalWVdWVd2WV cVal)

findMaxTermIndex

public int findMaxTermIndex(water.fvec.Chunk[] chks,
                            int rowInd,
                            int colInd)

calLogZ

public double calLogZ(water.fvec.Chunk[] chks,
                      int rInd,
                      int zConstCol)

calLogWVMax

public double calLogWVMax(water.fvec.Chunk[] chks,
                          int rowInd,
                          int indexMax,
                          double logZ)

evalDlldPhi

public double evalDlldPhi(water.fvec.Chunk[] chks,
                          int rowInd,
                          double sumDWVj,
                          double oneOverSumWVj,
                          java.util.Map<DispersionTask.ConstColNames,java.lang.Integer> constColName2Ind)

evalD2lldPhi2

public double evalD2lldPhi2(water.fvec.Chunk[] chks,
                            int rowInd,
                            double sumDWVj,
                            double sumD2WVj,
                            double oneOverSumWVj,
                            java.util.Map<DispersionTask.ConstColNames,java.lang.Integer> constColName2Ind)

evalLogLikelihood

public double evalLogLikelihood(water.fvec.Chunk[] chks,
                                int rowInd,
                                double sumWV,
                                java.util.Map<DispersionTask.ConstColNames,java.lang.Integer> constColName2Ind)