water.fvec

Class RollupStats

java.lang.Object

jsr166y.ForkJoinTask<java.lang.Void>

jsr166y.CountedCompleter

water.H2O.H2OCountedCompleter

water.DTask<RollupStats>

water.fvec.RollupStats

All Implemented Interfaces:

java.io.Serializable, java.lang.Cloneable, java.util.concurrent.Future<java.lang.Void>, Freezable

public class RollupStats
extends DTask<RollupStats>

A class to compute the rollup stats. These are computed lazily, thrown away if the Vec is written into, and then recomputed lazily. Error to ask for them if the Vec is actively being written into. It is common for all cores to ask for the same Vec rollup at once, so it is crucial that it be computed once across the cluster. Rollups are kept in the K/V store, which also controls who manages the rollup work and final results. Winner of a DKV CAS/PutIfMatch race gets to manage the M/R job computing the rollups. Losers block for the same rollup. Remote requests *always* forward to the Rollup Key's master.

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
long[]	_bins
boolean	_isInt
double[]	_maxs
double	_mean
double[]	_mins
long	_naCnt The count of missing elements....
long	_ninfs
long	_nzCnt
double[]	_pctiles
long	_pinfs
long	_rows
double	_sigma
long	_size
static double[]	PERCENTILES

Fields inherited from class water.DTask

_ex

Method Summary

Methods

Modifier and Type	Method and Description
protected void	compute2()
static void	computeHisto(Vec vec)
double	h_base()
double	h_stride()
byte	priority()

Methods inherited from class water.DTask

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

Methods inherited from class water.H2O.H2OCountedCompleter

clone, compute, frozenType, icer, nextThrPriority, onExceptionalCompletion, read_impl, read, readJSON_impl, readJSON, write_impl, write, writeHTML_impl, writeHTML, writeJSON_impl, writeJSON

Methods inherited from class jsr166y.CountedCompleter

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

Methods inherited from class jsr166y.ForkJoinTask

adapt, adapt, adapt, cancel, compareAndSetForkJoinTaskTag, completeExceptionally, fork, 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

Methods inherited from interface water.Freezable

clone, frozenType, read_impl, read, readJSON_impl, readJSON, write_impl, write, writeHTML_impl, writeHTML, writeJSON_impl, writeJSON

Field Detail

_naCnt

public long _naCnt

The count of missing elements.... or -2 if we have active writers and no rollup info can be computed (because the vector is being rapidly modified!), or -1 if rollups have not been computed since the last modification.

_mean

public double _mean

_sigma

public double _sigma

_rows

public long _rows

_nzCnt

public long _nzCnt

_size

public long _size

_pinfs

public long _pinfs

_ninfs

public long _ninfs

_isInt

public boolean _isInt

_mins

public double[] _mins

_maxs

public double[] _maxs

_bins

public volatile long[] _bins

PERCENTILES

public static final double[] PERCENTILES

_pctiles

public double[] _pctiles

Method Detail

priority

public byte priority()

Overrides:

priority in class H2O.H2OCountedCompleter

compute2

protected void compute2()

Specified by:

compute2 in class H2O.H2OCountedCompleter

computeHisto

public static void computeHisto(Vec vec)

h_base

public double h_base()

h_stride

public double h_stride()