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

Class GenericUDAFComputeStats.GenericUDAFNumericStatsEvaluator.NumericStatsAgg

java.lang.Object

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

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

All Implemented Interfaces:

GenericUDAFEvaluator.AggregationBuffer

Direct Known Subclasses:

GenericUDAFComputeStats.GenericUDAFDateStatsEvaluator.DateStatsAgg, GenericUDAFComputeStats.GenericUDAFDecimalStatsEvaluator.DecimalStatsAgg, GenericUDAFComputeStats.GenericUDAFDoubleStatsEvaluator.DoubleStatsAgg, GenericUDAFComputeStats.GenericUDAFLongStatsEvaluator.LongStatsAgg

Enclosing class:

GenericUDAFComputeStats.GenericUDAFNumericStatsEvaluator<V,OI extends ObjectInspector>

public abstract class GenericUDAFComputeStats.GenericUDAFNumericStatsEvaluator.NumericStatsAgg
extends GenericUDAFEvaluator.AbstractAggregationBuffer

Field Summary

Fields

Modifier and Type	Field and Description
String	columnType
long	countNulls
V	max
V	min
NumDistinctValueEstimator	numDV

Constructor Summary

Constructors

Constructor and Description
GenericUDAFComputeStats.GenericUDAFNumericStatsEvaluator.NumericStatsAgg()

Method Summary

Methods

Modifier and Type	Method and Description
int	estimate() Estimate the size of memory which is occupied by aggregation buffer.
protected void	initNDVEstimator(int numBitVectors)
void	reset(String type)
protected Object	serialize(Object[] result)
protected Object	serializePartial(Object[] result)
protected abstract void	update(Object p, PrimitiveObjectInspector inputOI)
protected abstract void	updateMax(Object maxValue, OI maxOI)
protected abstract void	updateMin(Object minValue, OI minOI)

Methods inherited from class java.lang.Object

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

Field Detail

columnType

public String columnType

min

public V min

max

public V max

countNulls

public long countNulls

numDV

public NumDistinctValueEstimator numDV

Constructor Detail

GenericUDAFComputeStats.GenericUDAFNumericStatsEvaluator.NumericStatsAgg

public GenericUDAFComputeStats.GenericUDAFNumericStatsEvaluator.NumericStatsAgg()

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 GenericUDAFEvaluator.AbstractAggregationBuffer

initNDVEstimator

protected void initNDVEstimator(int numBitVectors)

update

protected abstract void update(Object p,
          PrimitiveObjectInspector inputOI)

updateMin

protected abstract void updateMin(Object minValue,
             OI minOI)

updateMax

protected abstract void updateMax(Object maxValue,
             OI maxOI)

serialize

protected Object serialize(Object[] result)

serializePartial

protected Object serializePartial(Object[] result)

reset

public void reset(String type)
           throws HiveException

Throws:

HiveException