org.apache.hadoop.hive.ql.exec.vector.expressions.aggregates.gen

Class VectorUDAFMinLong

java.lang.Object

org.apache.hadoop.hive.ql.exec.vector.expressions.aggregates.VectorAggregateExpression

org.apache.hadoop.hive.ql.exec.vector.expressions.aggregates.gen.VectorUDAFMinLong

All Implemented Interfaces:

Serializable

public class VectorUDAFMinLong
extends VectorAggregateExpression

VectorUDAFMinLong. Vectorized implementation for MIN/MAX aggregates.

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.hadoop.hive.ql.exec.vector.expressions.aggregates.VectorAggregateExpression

VectorAggregateExpression.AggregationBuffer

Constructor Summary

Constructors

Constructor and Description
VectorUDAFMinLong()
VectorUDAFMinLong(VectorExpression inputExpression)

Method Summary

Modifier and Type	Method and Description
void	aggregateInput(VectorAggregateExpression.AggregationBuffer agg, org.apache.hadoop.hive.ql.exec.vector.VectorizedRowBatch batch)
void	aggregateInputSelection(VectorAggregationBufferRow[] aggregationBufferSets, int aggregrateIndex, org.apache.hadoop.hive.ql.exec.vector.VectorizedRowBatch batch)
Object	evaluateOutput(VectorAggregateExpression.AggregationBuffer agg)
int	getAggregationBufferFixedSize()
VectorExpression	getInputExpression()
VectorAggregateExpression.AggregationBuffer	getNewAggregationBuffer()
ObjectInspector	getOutputObjectInspector()
void	init(AggregationDesc desc)
VectorExpression	inputExpression()
void	reset(VectorAggregateExpression.AggregationBuffer agg)
void	setInputExpression(VectorExpression inputExpression)

Methods inherited from class org.apache.hadoop.hive.ql.exec.vector.expressions.aggregates.VectorAggregateExpression

hasVariableSize, toString

Methods inherited from class java.lang.Object

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

Constructor Detail

VectorUDAFMinLong

public VectorUDAFMinLong(VectorExpression inputExpression)

VectorUDAFMinLong

public VectorUDAFMinLong()

Method Detail

inputExpression

public VectorExpression inputExpression()

Specified by:

inputExpression in class VectorAggregateExpression

init

public void init(AggregationDesc desc)
          throws HiveException

Specified by:

init in class VectorAggregateExpression

Throws:

HiveException

aggregateInputSelection

public void aggregateInputSelection(VectorAggregationBufferRow[] aggregationBufferSets,
                                    int aggregrateIndex,
                                    org.apache.hadoop.hive.ql.exec.vector.VectorizedRowBatch batch)
                             throws HiveException

Specified by:

aggregateInputSelection in class VectorAggregateExpression

Throws:

HiveException

aggregateInput

public void aggregateInput(VectorAggregateExpression.AggregationBuffer agg,
                           org.apache.hadoop.hive.ql.exec.vector.VectorizedRowBatch batch)
                    throws HiveException

Specified by:

aggregateInput in class VectorAggregateExpression

Throws:

HiveException

getNewAggregationBuffer

public VectorAggregateExpression.AggregationBuffer getNewAggregationBuffer()
                                                                    throws HiveException

Specified by:

getNewAggregationBuffer in class VectorAggregateExpression

Throws:

HiveException

reset

public void reset(VectorAggregateExpression.AggregationBuffer agg)
           throws HiveException

Specified by:

reset in class VectorAggregateExpression

Throws:

HiveException

evaluateOutput

public Object evaluateOutput(VectorAggregateExpression.AggregationBuffer agg)
                      throws HiveException

Specified by:

evaluateOutput in class VectorAggregateExpression

Throws:

HiveException

getOutputObjectInspector

public ObjectInspector getOutputObjectInspector()

Specified by:

getOutputObjectInspector in class VectorAggregateExpression

getAggregationBufferFixedSize

public int getAggregationBufferFixedSize()

Specified by:

getAggregationBufferFixedSize in class VectorAggregateExpression

getInputExpression

public VectorExpression getInputExpression()

setInputExpression

public void setInputExpression(VectorExpression inputExpression)