public static class GenericUDAFAverage.GenericUDAFAverageEvaluatorDouble extends GenericUDAFAverage.AbstractGenericUDAFAverageEvaluator<Double>
GenericUDAFEvaluator.AbstractAggregationBuffer, GenericUDAFEvaluator.AggregationBuffer, GenericUDAFEvaluator.AggregationType, GenericUDAFEvaluator.Mode
avgDistinct, copiedOI, inputOI, isWindowing, partialResult, sumFieldOI
partitionEvaluator
Constructor and Description |
---|
GenericUDAFAverageEvaluatorDouble() |
Modifier and Type | Method and Description |
---|---|
protected BasePartitionEvaluator |
createPartitionEvaluator(WindowFrameDef winFrame,
PTFPartition partition,
List<PTFExpressionDef> parameters,
ObjectInspector outputOI)
This class needs to be overridden by the child class to implement function
specific evaluator.
|
protected void |
doIterate(org.apache.hadoop.hive.ql.udf.generic.GenericUDAFAverage.AverageAggregationBuffer<Double> aggregation,
PrimitiveObjectInspector oi,
Object parameter) |
protected void |
doMerge(org.apache.hadoop.hive.ql.udf.generic.GenericUDAFAverage.AverageAggregationBuffer<Double> aggregation,
Long partialCount,
ObjectInspector sumFieldOI,
Object partialSum) |
protected void |
doMergeAdd(Double sum,
ObjectInspectorUtils.ObjectInspectorObject obj) |
void |
doReset(org.apache.hadoop.hive.ql.udf.generic.GenericUDAFAverage.AverageAggregationBuffer<Double> aggregation) |
protected Object |
doTerminate(org.apache.hadoop.hive.ql.udf.generic.GenericUDAFAverage.AverageAggregationBuffer<Double> aggregation) |
protected void |
doTerminatePartial(org.apache.hadoop.hive.ql.udf.generic.GenericUDAFAverage.AverageAggregationBuffer<Double> aggregation) |
GenericUDAFEvaluator.AggregationBuffer |
getNewAggregationBuffer()
Get a new aggregation object.
|
protected ObjectInspector |
getSumFieldJavaObjectInspector() |
protected ObjectInspector |
getSumFieldWritableObjectInspector() |
GenericUDAFEvaluator |
getWindowingEvaluator(WindowFrameDef wFrameDef)
When evaluating an aggregates over a fixed Window, the naive way to compute
results is to compute the aggregate for each row.
|
init, isWindowingDistinct, iterate, merge, reset, terminate, terminatePartial
aggregate, close, configure, evaluate, getExprString, getPartitionWindowingEvaluator, isEstimable
public void doReset(org.apache.hadoop.hive.ql.udf.generic.GenericUDAFAverage.AverageAggregationBuffer<Double> aggregation) throws HiveException
doReset
in class GenericUDAFAverage.AbstractGenericUDAFAverageEvaluator<Double>
HiveException
protected ObjectInspector getSumFieldJavaObjectInspector()
getSumFieldJavaObjectInspector
in class GenericUDAFAverage.AbstractGenericUDAFAverageEvaluator<Double>
protected ObjectInspector getSumFieldWritableObjectInspector()
getSumFieldWritableObjectInspector
in class GenericUDAFAverage.AbstractGenericUDAFAverageEvaluator<Double>
protected void doIterate(org.apache.hadoop.hive.ql.udf.generic.GenericUDAFAverage.AverageAggregationBuffer<Double> aggregation, PrimitiveObjectInspector oi, Object parameter)
doIterate
in class GenericUDAFAverage.AbstractGenericUDAFAverageEvaluator<Double>
protected void doMerge(org.apache.hadoop.hive.ql.udf.generic.GenericUDAFAverage.AverageAggregationBuffer<Double> aggregation, Long partialCount, ObjectInspector sumFieldOI, Object partialSum)
doMerge
in class GenericUDAFAverage.AbstractGenericUDAFAverageEvaluator<Double>
protected void doMergeAdd(Double sum, ObjectInspectorUtils.ObjectInspectorObject obj)
doMergeAdd
in class GenericUDAFAverage.AbstractGenericUDAFAverageEvaluator<Double>
protected void doTerminatePartial(org.apache.hadoop.hive.ql.udf.generic.GenericUDAFAverage.AverageAggregationBuffer<Double> aggregation)
doTerminatePartial
in class GenericUDAFAverage.AbstractGenericUDAFAverageEvaluator<Double>
protected Object doTerminate(org.apache.hadoop.hive.ql.udf.generic.GenericUDAFAverage.AverageAggregationBuffer<Double> aggregation)
doTerminate
in class GenericUDAFAverage.AbstractGenericUDAFAverageEvaluator<Double>
public GenericUDAFEvaluator.AggregationBuffer getNewAggregationBuffer() throws HiveException
GenericUDAFEvaluator
getNewAggregationBuffer
in class GenericUDAFEvaluator
HiveException
public GenericUDAFEvaluator getWindowingEvaluator(WindowFrameDef wFrameDef)
GenericUDAFEvaluator
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.
getWindowingEvaluator
in class GenericUDAFEvaluator
wFrameDef
- the Window definition in play for this evaluation.protected BasePartitionEvaluator createPartitionEvaluator(WindowFrameDef winFrame, PTFPartition partition, List<PTFExpressionDef> parameters, ObjectInspector outputOI)
GenericUDAFEvaluator
createPartitionEvaluator
in class GenericUDAFEvaluator
Copyright © 2021 The Apache Software Foundation. All rights reserved.