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 org.apache.hadoop.hive.common.type.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) |
Modifier and Type | Method and Description |
---|---|
abstract void |
aggregateInput(VectorAggregateExpression.AggregationBuffer agg,
org.apache.hadoop.hive.ql.exec.vector.VectorizedRowBatch unit) |
abstract void |
aggregateInputSelection(VectorAggregationBufferRow[] aggregationBufferSets,
int aggregateIndex,
org.apache.hadoop.hive.ql.exec.vector.VectorizedRowBatch vrg) |
abstract void |
assignRowColumn(org.apache.hadoop.hive.ql.exec.vector.VectorizedRowBatch batch,
int batchIndex,
int columnNum,
VectorAggregateExpression.AggregationBuffer agg) |
abstract long |
getAggregationBufferFixedSize() |
VectorExpression |
getInputExpression() |
abstract VectorAggregateExpression.AggregationBuffer |
getNewAggregationBuffer() |
org.apache.hadoop.hive.common.type.DataTypePhysicalVariation |
getOutputDataTypePhysicalVariation() |
TypeInfo |
getOutputTypeInfo() |
boolean |
hasVariableSize() |
abstract boolean |
matches(String name,
org.apache.hadoop.hive.ql.exec.vector.ColumnVector.Type inputColVectorType,
org.apache.hadoop.hive.ql.exec.vector.ColumnVector.Type outputColVectorType,
GenericUDAFEvaluator.Mode mode) |
abstract void |
reset(VectorAggregateExpression.AggregationBuffer agg) |
String |
toString() |
protected final VectorAggregationDesc vecAggrDesc
protected final VectorExpression inputExpression
protected final TypeInfo inputTypeInfo
protected final TypeInfo outputTypeInfo
protected final org.apache.hadoop.hive.common.type.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 org.apache.hadoop.hive.common.type.DataTypePhysicalVariation getOutputDataTypePhysicalVariation()
public abstract VectorAggregateExpression.AggregationBuffer getNewAggregationBuffer() throws HiveException
HiveException
public abstract void aggregateInput(VectorAggregateExpression.AggregationBuffer agg, org.apache.hadoop.hive.ql.exec.vector.VectorizedRowBatch unit) throws HiveException
HiveException
public abstract void aggregateInputSelection(VectorAggregationBufferRow[] aggregationBufferSets, int aggregateIndex, org.apache.hadoop.hive.ql.exec.vector.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, org.apache.hadoop.hive.ql.exec.vector.ColumnVector.Type inputColVectorType, org.apache.hadoop.hive.ql.exec.vector.ColumnVector.Type outputColVectorType, GenericUDAFEvaluator.Mode mode)
public abstract void assignRowColumn(org.apache.hadoop.hive.ql.exec.vector.VectorizedRowBatch batch, int batchIndex, int columnNum, VectorAggregateExpression.AggregationBuffer agg) throws HiveException
HiveException
Copyright © 2022 The Apache Software Foundation. All rights reserved.