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

Class GenericUDAFStreamingEvaluator.SumAvgEnhancer<T1,T2>

java.lang.Object

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

org.apache.hadoop.hive.ql.udf.generic.GenericUDAFStreamingEvaluator<T1>

org.apache.hadoop.hive.ql.udf.generic.GenericUDAFStreamingEvaluator.SumAvgEnhancer<T1,T2>

All Implemented Interfaces:

Closeable, AutoCloseable, ISupportStreamingModeForWindowing

Enclosing class:

GenericUDAFStreamingEvaluator<T1>

public abstract static class GenericUDAFStreamingEvaluator.SumAvgEnhancer<T1,T2>
extends GenericUDAFStreamingEvaluator<T1>

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.hadoop.hive.ql.udf.generic.GenericUDAFStreamingEvaluator

GenericUDAFStreamingEvaluator.SumAvgEnhancer<T1,T2>

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.GenericUDAFStreamingEvaluator

wFrameDef, wrappedEval

Fields inherited from interface org.apache.hadoop.hive.ql.udf.generic.ISupportStreamingModeForWindowing

NULL_RESULT

Constructor Summary

Constructors

Constructor and Description
SumAvgEnhancer(GenericUDAFEvaluator wrappedEval, WindowFrameDef wFrameDef)

Method Summary

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.

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

getNextResult, init, merge, reset, terminatePartial

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

aggregate, close, configure, evaluate, getWindowingEvaluator, isEstimable

Methods inherited from class java.lang.Object

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

Constructor Detail

SumAvgEnhancer

public SumAvgEnhancer(GenericUDAFEvaluator wrappedEval,
                      WindowFrameDef wFrameDef)

Method Detail

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

iterate

public void iterate(GenericUDAFEvaluator.AggregationBuffer agg,
                    Object[] parameters)
             throws HiveException

Description copied from class: GenericUDAFEvaluator

Iterate through original data.

Specified by:

iterate in class GenericUDAFEvaluator

parameters - The objects of parameters.

Throws:

HiveException

terminate

public Object terminate(GenericUDAFEvaluator.AggregationBuffer agg)
                 throws HiveException

Description copied from class: GenericUDAFEvaluator

Get final aggregation result.

Specified by:

terminate in class GenericUDAFEvaluator

Returns:

final aggregation result.

Throws:

HiveException

getRowsRemainingAfterTerminate

public int getRowsRemainingAfterTerminate()
                                   throws HiveException

Throws:

HiveException

getNextResult

protected abstract T1 getNextResult(org.apache.hadoop.hive.ql.udf.generic.GenericUDAFStreamingEvaluator.SumAvgEnhancer.SumAvgStreamingState ss)
                             throws HiveException

Throws:

HiveException

getCurrentIntermediateResult

protected abstract T2 getCurrentIntermediateResult(org.apache.hadoop.hive.ql.udf.generic.GenericUDAFStreamingEvaluator.SumAvgEnhancer.SumAvgStreamingState ss)
                                            throws HiveException

Throws:

HiveException