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

Class GenericUDAFSum.GenericUDAFSumEvaluator<ResultType extends org.apache.hadoop.io.Writable>

java.lang.Object

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

org.apache.hadoop.hive.ql.udf.generic.GenericUDAFSum.GenericUDAFSumEvaluator<ResultType>

All Implemented Interfaces:

Closeable, AutoCloseable

Direct Known Subclasses:

GenericUDAFSum.GenericUDAFSumDouble, GenericUDAFSum.GenericUDAFSumHiveDecimal, GenericUDAFSum.GenericUDAFSumLong

Enclosing class:

GenericUDAFSum

public abstract static class GenericUDAFSum.GenericUDAFSumEvaluator<ResultType extends org.apache.hadoop.io.Writable>
extends GenericUDAFEvaluator

The base type for sum operator evaluator

Nested Class Summary

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

Modifier and Type	Field and Description
protected PrimitiveObjectInspector	inputOI
protected boolean	isWindowing
protected PrimitiveObjectInspector	outputOI
protected ResultType	result
protected boolean	sumDistinct

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

partitionEvaluator

Constructor Summary

Constructors

Constructor and Description
GenericUDAFSumEvaluator()

Method Summary

Modifier and Type	Method and Description
protected boolean	isEligibleValue(org.apache.hadoop.hive.ql.udf.generic.GenericUDAFSum.GenericUDAFSumEvaluator.SumAgg agg, Object input) Check if the input object is eligible to contribute to the sum.
boolean	isWindowingDistinct()
void	setSumDistinct(boolean sumDistinct)
void	setWindowing(boolean isWindowing)
Object	terminatePartial(GenericUDAFEvaluator.AggregationBuffer agg) Get partial aggregation result.

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

aggregate, close, configure, createPartitionEvaluator, estimate, evaluate, getExprString, getNewAggregationBuffer, getPartitionWindowingEvaluator, getWindowingEvaluator, init, isEstimable, iterate, merge, reset, terminate

Methods inherited from class java.lang.Object

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

Field Detail

inputOI

protected PrimitiveObjectInspector inputOI

outputOI

protected PrimitiveObjectInspector outputOI

result

protected ResultType extends org.apache.hadoop.io.Writable result

isWindowing

protected boolean isWindowing

sumDistinct

protected boolean sumDistinct

Constructor Detail

GenericUDAFSumEvaluator

public GenericUDAFSumEvaluator()

Method Detail

setWindowing

public void setWindowing(boolean isWindowing)

setSumDistinct

public void setSumDistinct(boolean sumDistinct)

isWindowingDistinct

public boolean isWindowingDistinct()

terminatePartial

public Object terminatePartial(GenericUDAFEvaluator.AggregationBuffer agg)
                        throws HiveException

Description copied from class: GenericUDAFEvaluator

Get partial aggregation result.

Specified by:

terminatePartial in class GenericUDAFEvaluator

Returns:

partial aggregation result.

Throws:

HiveException

isEligibleValue

protected boolean isEligibleValue(org.apache.hadoop.hive.ql.udf.generic.GenericUDAFSum.GenericUDAFSumEvaluator.SumAgg agg,
                                  Object input)

Check if the input object is eligible to contribute to the sum. If it's null or the same value as the previous one for the case of SUM(DISTINCT). Then skip it.

Parameters:

input - the input object

Returns:

True if sumDistinct is false or the non-null input is different from the previous object