public abstract class VectorAggregateExpression extends Object implements Serializable
Modifier and Type | Class and Description |
---|---|
static interface |
VectorAggregateExpression.AggregationBuffer
Buffer interface to store aggregates.
|
Modifier and Type | Field and Description |
---|---|
static int |
AVERAGE_COUNT_FIELD_INDEX |
static int |
AVERAGE_SOURCE_FIELD_INDEX |
static int |
AVERAGE_SUM_FIELD_INDEX |
protected VectorExpression |
inputExpression |
protected TypeInfo |
inputTypeInfo |
protected GenericUDAFEvaluator.Mode |
mode |
protected DataTypePhysicalVariation |
outputDataTypePhysicalVariation |
protected TypeInfo |
outputTypeInfo |
static int |
VARIANCE_COUNT_FIELD_INDEX |
static int |
VARIANCE_SUM_FIELD_INDEX |
static int |
VARIANCE_VARIANCE_FIELD_INDEX |
protected VectorAggregationDesc |
vecAggrDesc |
Constructor and Description |
---|
VectorAggregateExpression() |
VectorAggregateExpression(VectorAggregationDesc vecAggrDesc) |
protected final VectorAggregationDesc vecAggrDesc
protected final VectorExpression inputExpression
protected final TypeInfo inputTypeInfo
protected final TypeInfo outputTypeInfo
protected final DataTypePhysicalVariation outputDataTypePhysicalVariation
protected final GenericUDAFEvaluator.Mode mode
public static final int AVERAGE_COUNT_FIELD_INDEX
public static final int AVERAGE_SUM_FIELD_INDEX
public static final int AVERAGE_SOURCE_FIELD_INDEX
public static final int VARIANCE_COUNT_FIELD_INDEX
public static final int VARIANCE_SUM_FIELD_INDEX
public static final int VARIANCE_VARIANCE_FIELD_INDEX
public VectorAggregateExpression()
public VectorAggregateExpression(VectorAggregationDesc vecAggrDesc)
public VectorExpression getInputExpression()
public TypeInfo getOutputTypeInfo()
public DataTypePhysicalVariation getOutputDataTypePhysicalVariation()
public abstract VectorAggregateExpression.AggregationBuffer getNewAggregationBuffer() throws HiveException
HiveException
public abstract void aggregateInput(VectorAggregateExpression.AggregationBuffer agg, VectorizedRowBatch unit) throws HiveException
HiveException
public abstract void aggregateInputSelection(VectorAggregationBufferRow[] aggregationBufferSets, int aggregateIndex, VectorizedRowBatch vrg) throws HiveException
HiveException
public abstract void reset(VectorAggregateExpression.AggregationBuffer agg) throws HiveException
HiveException
public abstract long getAggregationBufferFixedSize()
public boolean hasVariableSize()
public abstract boolean matches(String name, ColumnVector.Type inputColVectorType, ColumnVector.Type outputColVectorType, GenericUDAFEvaluator.Mode mode)
public abstract void assignRowColumn(VectorizedRowBatch batch, int batchIndex, int columnNum, VectorAggregateExpression.AggregationBuffer agg) throws HiveException
HiveException
public void finish(VectorAggregateExpression.AggregationBuffer aggregationBuffer, boolean aborted)
aggregationBuffer
- aborted
- Copyright © 2022 The Apache Software Foundation. All rights reserved.