org.apache.hadoop.hive.ql.exec.vector.expressions.aggregates
Class VectorUDAFSumDecimal
java.lang.Object
org.apache.hadoop.hive.ql.exec.vector.expressions.aggregates.VectorAggregateExpression
org.apache.hadoop.hive.ql.exec.vector.expressions.aggregates.VectorUDAFSumDecimal
- All Implemented Interfaces:
- Serializable
public class VectorUDAFSumDecimal
- extends VectorAggregateExpression
VectorUDAFSumDecimal. Vectorized implementation for SUM aggregates.
- See Also:
- Serialized Form
VectorUDAFSumDecimal
public VectorUDAFSumDecimal(VectorExpression inputExpression)
VectorUDAFSumDecimal
public VectorUDAFSumDecimal()
aggregateInputSelection
public void aggregateInputSelection(VectorAggregationBufferRow[] aggregationBufferSets,
int aggregateIndex,
VectorizedRowBatch batch)
throws HiveException
- Specified by:
aggregateInputSelection
in class VectorAggregateExpression
- Throws:
HiveException
aggregateInput
public void aggregateInput(VectorAggregateExpression.AggregationBuffer agg,
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
init
public void init(AggregationDesc desc)
throws HiveException
- Specified by:
init
in class VectorAggregateExpression
- Throws:
HiveException
getInputExpression
public VectorExpression getInputExpression()
setInputExpression
public void setInputExpression(VectorExpression inputExpression)
Copyright © 2014 The Apache Software Foundation. All rights reserved.