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

numFollowing, numPreceding, wrappedEval

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

NULL_RESULT

Constructor Summary

Constructors

Constructor and Description
GenericUDAFStreamingEvaluator.SumAvgEnhancer(GenericUDAFEvaluator wrappedEval, int numPreceding, int numFollowing)

Method Summary

Methods

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

GenericUDAFStreamingEvaluator.SumAvgEnhancer

public GenericUDAFStreamingEvaluator.SumAvgEnhancer(GenericUDAFEvaluator wrappedEval,
                                            int numPreceding,
                                            int numFollowing)

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