public abstract static class GenericUDAFStreamingEvaluator.SumAvgEnhancer<T1,T2> extends GenericUDAFStreamingEvaluator<T1>
GenericUDAFStreamingEvaluator.SumAvgEnhancer<T1,T2>
GenericUDAFEvaluator.AbstractAggregationBuffer, GenericUDAFEvaluator.AggregationBuffer, GenericUDAFEvaluator.AggregationType, GenericUDAFEvaluator.Mode
wFrameDef, wrappedEval
NULL_RESULT
Constructor and Description |
---|
SumAvgEnhancer(GenericUDAFEvaluator wrappedEval,
WindowFrameDef wFrameDef) |
Modifier and Type | Method and Description |
---|---|
protected abstract T2 |
getCurrentIntermediateResult(org.apache.hadoop.hive.ql.udf.generic.GenericUDAFStreamingEvaluator.SumAvgEnhancer.SumAvgStreamingState ss) |
GenericUDAFEvaluator.AggregationBuffer |
getNewAggregationBuffer()
Get a new aggregation object.
|
protected abstract T1 |
getNextResult(org.apache.hadoop.hive.ql.udf.generic.GenericUDAFStreamingEvaluator.SumAvgEnhancer.SumAvgStreamingState ss) |
int |
getRowsRemainingAfterTerminate() |
void |
iterate(GenericUDAFEvaluator.AggregationBuffer agg,
Object[] parameters)
Iterate through original data.
|
Object |
terminate(GenericUDAFEvaluator.AggregationBuffer agg)
Get final aggregation result.
|
getNextResult, init, merge, reset, terminatePartial
aggregate, close, configure, evaluate, getExprString, getWindowingEvaluator, isEstimable
public SumAvgEnhancer(GenericUDAFEvaluator wrappedEval, WindowFrameDef wFrameDef)
public GenericUDAFEvaluator.AggregationBuffer getNewAggregationBuffer() throws HiveException
GenericUDAFEvaluator
getNewAggregationBuffer
in class GenericUDAFEvaluator
HiveException
public void iterate(GenericUDAFEvaluator.AggregationBuffer agg, Object[] parameters) throws HiveException
GenericUDAFEvaluator
iterate
in class GenericUDAFEvaluator
parameters
- The objects of parameters.HiveException
public Object terminate(GenericUDAFEvaluator.AggregationBuffer agg) throws HiveException
GenericUDAFEvaluator
terminate
in class GenericUDAFEvaluator
HiveException
public int getRowsRemainingAfterTerminate() throws HiveException
HiveException
protected abstract T1 getNextResult(org.apache.hadoop.hive.ql.udf.generic.GenericUDAFStreamingEvaluator.SumAvgEnhancer.SumAvgStreamingState ss) throws HiveException
HiveException
protected abstract T2 getCurrentIntermediateResult(org.apache.hadoop.hive.ql.udf.generic.GenericUDAFStreamingEvaluator.SumAvgEnhancer.SumAvgStreamingState ss) throws HiveException
HiveException
Copyright © 2017 The Apache Software Foundation. All rights reserved.