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

Class GenericUDAFAverage.GenericUDAFAverageEvaluatorDecimal

java.lang.Object

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

org.apache.hadoop.hive.ql.udf.generic.GenericUDAFAverage.AbstractGenericUDAFAverageEvaluator<HiveDecimal>

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

All Implemented Interfaces:

Closeable, AutoCloseable

Enclosing class:

GenericUDAFAverage

public static class GenericUDAFAverage.GenericUDAFAverageEvaluatorDecimal
extends GenericUDAFAverage.AbstractGenericUDAFAverageEvaluator<HiveDecimal>

Nested Class Summary

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 inherited from class org.apache.hadoop.hive.ql.udf.generic.GenericUDAFAverage.AbstractGenericUDAFAverageEvaluator

inputOI, partialResult, sumFieldOI

Constructor Summary

Constructors

Constructor and Description
GenericUDAFAverage.GenericUDAFAverageEvaluatorDecimal()

Method Summary

Methods

Modifier and Type	Method and Description
protected void	doIterate(org.apache.hadoop.hive.ql.udf.generic.GenericUDAFAverage.AverageAggregationBuffer<HiveDecimal> aggregation, PrimitiveObjectInspector oi, Object parameter)
protected void	doMerge(org.apache.hadoop.hive.ql.udf.generic.GenericUDAFAverage.AverageAggregationBuffer<HiveDecimal> aggregation, Long partialCount, ObjectInspector sumFieldOI, Object partialSum)
void	doReset(org.apache.hadoop.hive.ql.udf.generic.GenericUDAFAverage.AverageAggregationBuffer<HiveDecimal> aggregation)
protected Object	doTerminate(org.apache.hadoop.hive.ql.udf.generic.GenericUDAFAverage.AverageAggregationBuffer<HiveDecimal> aggregation)
protected void	doTerminatePartial(org.apache.hadoop.hive.ql.udf.generic.GenericUDAFAverage.AverageAggregationBuffer<HiveDecimal> aggregation)
GenericUDAFEvaluator.AggregationBuffer	getNewAggregationBuffer() Get a new aggregation object.
protected ObjectInspector	getSumFieldJavaObjectInspector()
protected ObjectInspector	getSumFieldWritableObjectInspector()
GenericUDAFEvaluator	getWindowingEvaluator(WindowFrameDef wFrmDef) When evaluating an aggregates over a fixed Window, the naive way to compute results is to compute the aggregate for each row.

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

init, iterate, merge, reset, terminate, terminatePartial

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

aggregate, close, configure, evaluate, isEstimable

Methods inherited from class java.lang.Object

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

Constructor Detail

GenericUDAFAverage.GenericUDAFAverageEvaluatorDecimal

public GenericUDAFAverage.GenericUDAFAverageEvaluatorDecimal()

Method Detail

doReset

public void doReset(org.apache.hadoop.hive.ql.udf.generic.GenericUDAFAverage.AverageAggregationBuffer<HiveDecimal> aggregation)
             throws HiveException

Specified by:

doReset in class GenericUDAFAverage.AbstractGenericUDAFAverageEvaluator<HiveDecimal>

Throws:

HiveException

getSumFieldJavaObjectInspector

protected ObjectInspector getSumFieldJavaObjectInspector()

Specified by:

getSumFieldJavaObjectInspector in class GenericUDAFAverage.AbstractGenericUDAFAverageEvaluator<HiveDecimal>

getSumFieldWritableObjectInspector

protected ObjectInspector getSumFieldWritableObjectInspector()

Specified by:

getSumFieldWritableObjectInspector in class GenericUDAFAverage.AbstractGenericUDAFAverageEvaluator<HiveDecimal>

doIterate

protected void doIterate(org.apache.hadoop.hive.ql.udf.generic.GenericUDAFAverage.AverageAggregationBuffer<HiveDecimal> aggregation,
             PrimitiveObjectInspector oi,
             Object parameter)

Specified by:

doIterate in class GenericUDAFAverage.AbstractGenericUDAFAverageEvaluator<HiveDecimal>

doMerge

protected void doMerge(org.apache.hadoop.hive.ql.udf.generic.GenericUDAFAverage.AverageAggregationBuffer<HiveDecimal> aggregation,
           Long partialCount,
           ObjectInspector sumFieldOI,
           Object partialSum)

Specified by:

doMerge in class GenericUDAFAverage.AbstractGenericUDAFAverageEvaluator<HiveDecimal>

doTerminatePartial

protected void doTerminatePartial(org.apache.hadoop.hive.ql.udf.generic.GenericUDAFAverage.AverageAggregationBuffer<HiveDecimal> aggregation)

Specified by:

doTerminatePartial in class GenericUDAFAverage.AbstractGenericUDAFAverageEvaluator<HiveDecimal>

doTerminate

protected Object doTerminate(org.apache.hadoop.hive.ql.udf.generic.GenericUDAFAverage.AverageAggregationBuffer<HiveDecimal> aggregation)

Specified by:

doTerminate in class GenericUDAFAverage.AbstractGenericUDAFAverageEvaluator<HiveDecimal>

getNewAggregationBuffer

public GenericUDAFEvaluator.AggregationBuffer getNewAggregationBuffer()
                                                               throws HiveException

Description copied from class: GenericUDAFEvaluator

Get a new aggregation object.

Specified by:

getNewAggregationBuffer in class GenericUDAFEvaluator

Throws:

HiveException

getWindowingEvaluator

public GenericUDAFEvaluator getWindowingEvaluator(WindowFrameDef wFrmDef)

Description copied from class: GenericUDAFEvaluator

When evaluating an aggregates over a fixed Window, the naive way to compute results is to compute the aggregate for each row. But often there is a way to compute results in a more efficient manner. This method enables the basic evaluator to provide a function object that does the job in a more efficient manner.

This method is called after this Evaluator is initialized. The returned Function must be initialized. It is passed the 'window' of aggregation for each row.

Overrides:

getWindowingEvaluator in class GenericUDAFEvaluator

Parameters:

wFrmDef - the Window definition in play for this evaluation.

Returns:

null implies that this fn cannot be processed in Streaming mode. So each row is evaluated independently.