org.apache.hadoop.hive.ql.udf.generic

Class GenericUDAFComputeStats.GenericUDAFLongStatsEvaluator.LongStatsAgg

java.lang.Object

org.apache.hadoop.hive.ql.udf.generic.GenericUDAFEvaluator.AbstractAggregationBuffer

org.apache.hadoop.hive.ql.udf.generic.GenericUDAFComputeStats.GenericUDAFNumericStatsEvaluator.NumericStatsAgg

org.apache.hadoop.hive.ql.udf.generic.GenericUDAFComputeStats.GenericUDAFLongStatsEvaluator.LongStatsAgg

All Implemented Interfaces:

GenericUDAFEvaluator.AggregationBuffer

Enclosing class:

GenericUDAFComputeStats.GenericUDAFLongStatsEvaluator

public class GenericUDAFComputeStats.GenericUDAFLongStatsEvaluator.LongStatsAgg
extends GenericUDAFComputeStats.GenericUDAFNumericStatsEvaluator.NumericStatsAgg

Field Summary

Fields inherited from class org.apache.hadoop.hive.ql.udf.generic.GenericUDAFComputeStats.GenericUDAFNumericStatsEvaluator.NumericStatsAgg

columnType, countNulls, max, min, numDV

Constructor Summary

Constructors

Constructor and Description
GenericUDAFComputeStats.GenericUDAFLongStatsEvaluator.LongStatsAgg()

Method Summary

Methods

Modifier and Type	Method and Description
int	estimate() Estimate the size of memory which is occupied by aggregation buffer.
protected void	update(Object p, PrimitiveObjectInspector inputOI)
protected void	updateMax(Object maxValue, LongObjectInspector maxFieldOI)
protected void	updateMin(Object minValue, LongObjectInspector minFieldOI)

Methods inherited from class org.apache.hadoop.hive.ql.udf.generic.GenericUDAFComputeStats.GenericUDAFNumericStatsEvaluator.NumericStatsAgg

initNDVEstimator, reset, serialize, serializePartial

Methods inherited from class java.lang.Object

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

Constructor Detail

GenericUDAFComputeStats.GenericUDAFLongStatsEvaluator.LongStatsAgg

public GenericUDAFComputeStats.GenericUDAFLongStatsEvaluator.LongStatsAgg()

Method Detail

estimate

public int estimate()

Description copied from class: GenericUDAFEvaluator.AbstractAggregationBuffer

Estimate the size of memory which is occupied by aggregation buffer. Currently, hive assumes that primitives types occupies 16 byte and java object has 64 byte overhead for each. For map, each entry also has 64 byte overhead.

Overrides:

estimate in class GenericUDAFComputeStats.GenericUDAFNumericStatsEvaluator.NumericStatsAgg

update

protected void update(Object p,
          PrimitiveObjectInspector inputOI)

Specified by:

update in class GenericUDAFComputeStats.GenericUDAFNumericStatsEvaluator.NumericStatsAgg

updateMin

protected void updateMin(Object minValue,
             LongObjectInspector minFieldOI)

Specified by:

updateMin in class GenericUDAFComputeStats.GenericUDAFNumericStatsEvaluator.NumericStatsAgg

updateMax

protected void updateMax(Object maxValue,
             LongObjectInspector maxFieldOI)

Specified by:

updateMax in class GenericUDAFComputeStats.GenericUDAFNumericStatsEvaluator.NumericStatsAgg