public static class GenericUDAFAverage.GenericUDAFAverageEvaluatorDouble extends GenericUDAFAverage.AbstractGenericUDAFAverageEvaluator<java.lang.Double>
GenericUDAFEvaluator.AbstractAggregationBuffer, GenericUDAFEvaluator.AggregationBuffer, GenericUDAFEvaluator.AggregationType, GenericUDAFEvaluator.Mode
partialResult
Constructor and Description |
---|
GenericUDAFAverageEvaluatorDouble() |
Modifier and Type | Method and Description |
---|---|
protected void |
doIterate(org.apache.hadoop.hive.ql.udf.generic.GenericUDAFAverage.AverageAggregationBuffer<java.lang.Double> aggregation,
PrimitiveObjectInspector oi,
java.lang.Object parameter) |
protected void |
doMerge(org.apache.hadoop.hive.ql.udf.generic.GenericUDAFAverage.AverageAggregationBuffer<java.lang.Double> aggregation,
java.lang.Long partialCount,
ObjectInspector sumFieldOI,
java.lang.Object partialSum) |
void |
doReset(org.apache.hadoop.hive.ql.udf.generic.GenericUDAFAverage.AverageAggregationBuffer<java.lang.Double> aggregation) |
protected java.lang.Object |
doTerminate(org.apache.hadoop.hive.ql.udf.generic.GenericUDAFAverage.AverageAggregationBuffer<java.lang.Double> aggregation) |
protected void |
doTerminatePartial(org.apache.hadoop.hive.ql.udf.generic.GenericUDAFAverage.AverageAggregationBuffer<java.lang.Double> aggregation) |
GenericUDAFEvaluator.AggregationBuffer |
getNewAggregationBuffer()
Get a new aggregation object.
|
protected ObjectInspector |
getSumFieldJavaObjectInspector() |
protected ObjectInspector |
getSumFieldWritableObjectInspector() |
init, iterate, merge, reset, terminate, terminatePartial
aggregate, close, configure, evaluate, isEstimable
public void doReset(org.apache.hadoop.hive.ql.udf.generic.GenericUDAFAverage.AverageAggregationBuffer<java.lang.Double> aggregation) throws HiveException
doReset
in class GenericUDAFAverage.AbstractGenericUDAFAverageEvaluator<java.lang.Double>
HiveException
protected ObjectInspector getSumFieldJavaObjectInspector()
getSumFieldJavaObjectInspector
in class GenericUDAFAverage.AbstractGenericUDAFAverageEvaluator<java.lang.Double>
protected ObjectInspector getSumFieldWritableObjectInspector()
getSumFieldWritableObjectInspector
in class GenericUDAFAverage.AbstractGenericUDAFAverageEvaluator<java.lang.Double>
protected void doIterate(org.apache.hadoop.hive.ql.udf.generic.GenericUDAFAverage.AverageAggregationBuffer<java.lang.Double> aggregation, PrimitiveObjectInspector oi, java.lang.Object parameter)
doIterate
in class GenericUDAFAverage.AbstractGenericUDAFAverageEvaluator<java.lang.Double>
protected void doMerge(org.apache.hadoop.hive.ql.udf.generic.GenericUDAFAverage.AverageAggregationBuffer<java.lang.Double> aggregation, java.lang.Long partialCount, ObjectInspector sumFieldOI, java.lang.Object partialSum)
doMerge
in class GenericUDAFAverage.AbstractGenericUDAFAverageEvaluator<java.lang.Double>
protected void doTerminatePartial(org.apache.hadoop.hive.ql.udf.generic.GenericUDAFAverage.AverageAggregationBuffer<java.lang.Double> aggregation)
doTerminatePartial
in class GenericUDAFAverage.AbstractGenericUDAFAverageEvaluator<java.lang.Double>
protected java.lang.Object doTerminate(org.apache.hadoop.hive.ql.udf.generic.GenericUDAFAverage.AverageAggregationBuffer<java.lang.Double> aggregation)
doTerminate
in class GenericUDAFAverage.AbstractGenericUDAFAverageEvaluator<java.lang.Double>
public GenericUDAFEvaluator.AggregationBuffer getNewAggregationBuffer() throws HiveException
GenericUDAFEvaluator
getNewAggregationBuffer
in class GenericUDAFEvaluator
HiveException
Copyright © 2012 The Apache Software Foundation