public class VectorUDAFCountMerge extends VectorAggregateExpression
VectorAggregateExpression.AggregationBuffer
Constructor and Description |
---|
VectorUDAFCountMerge() |
VectorUDAFCountMerge(VectorExpression inputExpression) |
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 aggregateIndex,
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) |
void |
reset(VectorAggregateExpression.AggregationBuffer agg) |
void |
setInputExpression(VectorExpression inputExpression) |
hasVariableSize
public VectorUDAFCountMerge(VectorExpression inputExpression)
public VectorUDAFCountMerge()
public void aggregateInputSelection(VectorAggregationBufferRow[] aggregationBufferSets, int aggregateIndex, org.apache.hadoop.hive.ql.exec.vector.VectorizedRowBatch batch) throws HiveException
aggregateInputSelection
in class VectorAggregateExpression
HiveException
public void aggregateInput(VectorAggregateExpression.AggregationBuffer agg, org.apache.hadoop.hive.ql.exec.vector.VectorizedRowBatch batch) throws HiveException
aggregateInput
in class VectorAggregateExpression
HiveException
public VectorAggregateExpression.AggregationBuffer getNewAggregationBuffer() throws HiveException
getNewAggregationBuffer
in class VectorAggregateExpression
HiveException
public void reset(VectorAggregateExpression.AggregationBuffer agg) throws HiveException
reset
in class VectorAggregateExpression
HiveException
public Object evaluateOutput(VectorAggregateExpression.AggregationBuffer agg) throws HiveException
evaluateOutput
in class VectorAggregateExpression
HiveException
public ObjectInspector getOutputObjectInspector()
getOutputObjectInspector
in class VectorAggregateExpression
public int getAggregationBufferFixedSize()
getAggregationBufferFixedSize
in class VectorAggregateExpression
public void init(AggregationDesc desc) throws HiveException
init
in class VectorAggregateExpression
HiveException
public VectorExpression getInputExpression()
public void setInputExpression(VectorExpression inputExpression)
Copyright © 2017 The Apache Software Foundation. All rights reserved.