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:

java.io.Closeable, java.lang.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

partialResult

Constructor Summary

Constructors

Constructor and Description
GenericUDAFAverageEvaluatorDecimal()

Method Summary

Modifier and Type	Method and Description
protected void	doIterate(org.apache.hadoop.hive.ql.udf.generic.GenericUDAFAverage.AverageAggregationBuffer<HiveDecimal> aggregation, PrimitiveObjectInspector oi, java.lang.Object parameter)
protected void	doMerge(org.apache.hadoop.hive.ql.udf.generic.GenericUDAFAverage.AverageAggregationBuffer<HiveDecimal> aggregation, java.lang.Long partialCount, ObjectInspector sumFieldOI, java.lang.Object partialSum)
void	doReset(org.apache.hadoop.hive.ql.udf.generic.GenericUDAFAverage.AverageAggregationBuffer<HiveDecimal> aggregation)
protected java.lang.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()

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

GenericUDAFAverageEvaluatorDecimal

public 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,
                         java.lang.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,
                       java.lang.Long partialCount,
                       ObjectInspector sumFieldOI,
                       java.lang.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 java.lang.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