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

Class GenericUDAFComputeStats.GenericUDAFNumericStatsEvaluator<V,OI extends PrimitiveObjectInspector>

java.lang.Object

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

org.apache.hadoop.hive.ql.udf.generic.GenericUDAFComputeStats.GenericUDAFNumericStatsEvaluator<V,OI>

All Implemented Interfaces:

Closeable, AutoCloseable

Direct Known Subclasses:

GenericUDAFComputeStats.GenericUDAFDateStatsEvaluator, GenericUDAFComputeStats.GenericUDAFDecimalStatsEvaluator, GenericUDAFComputeStats.GenericUDAFDoubleStatsEvaluator, GenericUDAFComputeStats.GenericUDAFLongStatsEvaluator

Enclosing class:

GenericUDAFComputeStats

public abstract static class GenericUDAFComputeStats.GenericUDAFNumericStatsEvaluator<V,OI extends PrimitiveObjectInspector>
extends GenericUDAFEvaluator

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	GenericUDAFComputeStats.GenericUDAFNumericStatsEvaluator.NumericStatsAgg

Nested classes/interfaces inherited from class org.apache.hadoop.hive.ql.udf.generic.GenericUDAFEvaluator

GenericUDAFEvaluator.AbstractAggregationBuffer, GenericUDAFEvaluator.AggregationBuffer, GenericUDAFEvaluator.AggregationType, GenericUDAFEvaluator.Mode

Field Summary

Fields

Modifier and Type	Field and Description
protected StructField	countNullsField
protected LongObjectInspector	countNullsFieldOI
protected PrimitiveObjectInspector	funcOI
protected PrimitiveObjectInspector	inputOI
protected static int	MAX_BIT_VECTORS
protected StructField	maxField
protected OI	maxFieldOI
protected StructField	minField
protected OI	minFieldOI
protected StructField	ndvField
protected BinaryObjectInspector	ndvFieldOI
protected PrimitiveObjectInspector	numVectorsOI
protected Object[]	partialResult
protected Object[]	result
protected StructObjectInspector	soi

Fields inherited from class org.apache.hadoop.hive.ql.udf.generic.GenericUDAFEvaluator

partitionEvaluator

Constructor Summary

Constructors

Constructor and Description
GenericUDAFNumericStatsEvaluator()

Method Summary

Modifier and Type	Method and Description
protected abstract OI	getValueObjectInspector()
protected abstract OI	getValueObjectInspector(PrimitiveTypeInfo typeInfo)
ObjectInspector	init(GenericUDAFEvaluator.Mode m, ObjectInspector[] parameters) Initialize the evaluator.
void	iterate(GenericUDAFEvaluator.AggregationBuffer agg, Object[] parameters) Iterate through original data.
void	merge(GenericUDAFEvaluator.AggregationBuffer agg, Object partial) Merge with partial aggregation result.
Object	terminate(GenericUDAFEvaluator.AggregationBuffer agg) Get final aggregation result.
Object	terminatePartial(GenericUDAFEvaluator.AggregationBuffer agg) Get partial aggregation result.

Methods inherited from class org.apache.hadoop.hive.ql.udf.generic.GenericUDAFEvaluator

aggregate, close, configure, createPartitionEvaluator, estimate, evaluate, getExprString, getNewAggregationBuffer, getPartitionWindowingEvaluator, getWindowingEvaluator, isEstimable, reset

Methods inherited from class java.lang.Object

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

Field Detail

MAX_BIT_VECTORS

protected static final int MAX_BIT_VECTORS

See Also:

Constant Field Values

inputOI

protected transient PrimitiveObjectInspector inputOI

funcOI

protected transient PrimitiveObjectInspector funcOI

numVectorsOI

protected transient PrimitiveObjectInspector numVectorsOI

soi

protected transient StructObjectInspector soi

minField

protected transient StructField minField

minFieldOI

protected transient OI extends PrimitiveObjectInspector minFieldOI

maxField

protected transient StructField maxField

maxFieldOI

protected transient OI extends PrimitiveObjectInspector maxFieldOI

countNullsField

protected transient StructField countNullsField

countNullsFieldOI

protected transient LongObjectInspector countNullsFieldOI

ndvField

protected transient StructField ndvField

ndvFieldOI

protected transient BinaryObjectInspector ndvFieldOI

partialResult

protected transient Object[] partialResult

result

protected transient Object[] result

Constructor Detail

GenericUDAFNumericStatsEvaluator

public GenericUDAFNumericStatsEvaluator()

Method Detail

getValueObjectInspector

protected abstract OI getValueObjectInspector()

getValueObjectInspector

protected abstract OI getValueObjectInspector(PrimitiveTypeInfo typeInfo)

init

public ObjectInspector init(GenericUDAFEvaluator.Mode m,
                            ObjectInspector[] parameters)
                     throws HiveException

Description copied from class: GenericUDAFEvaluator

Initialize the evaluator.

Overrides:

init in class GenericUDAFEvaluator

Parameters:

m - The mode of aggregation.

parameters - The ObjectInspector for the parameters: In PARTIAL1 and COMPLETE mode, the parameters are original data; In PARTIAL2 and FINAL mode, the parameters are just partial aggregations (in that case, the array will always have a single element).

Returns:

The ObjectInspector for the return value. In PARTIAL1 and PARTIAL2 mode, the ObjectInspector for the return value of terminatePartial() call; In FINAL and COMPLETE mode, the ObjectInspector for the return value of terminate() call. NOTE: We need ObjectInspector[] (in addition to the TypeInfo[] in GenericUDAFResolver) for 2 reasons: 1. ObjectInspector contains more information than TypeInfo; and GenericUDAFEvaluator.init at execution time. 2. We call GenericUDAFResolver.getEvaluator at compilation time,

Throws:

HiveException

iterate

public void iterate(GenericUDAFEvaluator.AggregationBuffer agg,
                    Object[] parameters)
             throws HiveException

Description copied from class: GenericUDAFEvaluator

Iterate through original data.

Specified by:

iterate in class GenericUDAFEvaluator

parameters - The objects of parameters.

Throws:

HiveException

terminatePartial

public Object terminatePartial(GenericUDAFEvaluator.AggregationBuffer agg)
                        throws HiveException

Description copied from class: GenericUDAFEvaluator

Get partial aggregation result.

Specified by:

terminatePartial in class GenericUDAFEvaluator

Returns:

partial aggregation result.

Throws:

HiveException

terminate

public Object terminate(GenericUDAFEvaluator.AggregationBuffer agg)
                 throws HiveException

Description copied from class: GenericUDAFEvaluator

Get final aggregation result.

Specified by:

terminate in class GenericUDAFEvaluator

Returns:

final aggregation result.

Throws:

HiveException

merge

public void merge(GenericUDAFEvaluator.AggregationBuffer agg,
                  Object partial)
           throws HiveException

Description copied from class: GenericUDAFEvaluator

Merge with partial aggregation result. NOTE: null might be passed in case there is no input data.

Specified by:

merge in class GenericUDAFEvaluator

partial - The partial aggregation result.

Throws:

HiveException