public class VectorUDAFVarTimestamp extends VectorAggregateExpression
VectorAggregateExpression.AggregationBuffer
AVERAGE_COUNT_FIELD_INDEX, AVERAGE_SOURCE_FIELD_INDEX, AVERAGE_SUM_FIELD_INDEX, inputExpression, inputTypeInfo, mode, outputDataTypePhysicalVariation, outputTypeInfo, VARIANCE_COUNT_FIELD_INDEX, VARIANCE_SUM_FIELD_INDEX, VARIANCE_VARIANCE_FIELD_INDEX, vecAggrDesc
Constructor and Description |
---|
VectorUDAFVarTimestamp() |
VectorUDAFVarTimestamp(VectorAggregationDesc vecAggrDesc) |
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) |
void |
assignRowColumn(org.apache.hadoop.hive.ql.exec.vector.VectorizedRowBatch batch,
int batchIndex,
int columnNum,
VectorAggregateExpression.AggregationBuffer agg) |
long |
getAggregationBufferFixedSize() |
VectorAggregateExpression.AggregationBuffer |
getNewAggregationBuffer() |
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) |
void |
reset(VectorAggregateExpression.AggregationBuffer agg) |
getInputExpression, getOutputDataTypePhysicalVariation, getOutputTypeInfo, hasVariableSize, toString
public VectorUDAFVarTimestamp()
public VectorUDAFVarTimestamp(VectorAggregationDesc vecAggrDesc)
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 long getAggregationBufferFixedSize()
getAggregationBufferFixedSize
in class VectorAggregateExpression
public 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)
matches
in class VectorAggregateExpression
public void assignRowColumn(org.apache.hadoop.hive.ql.exec.vector.VectorizedRowBatch batch, int batchIndex, int columnNum, VectorAggregateExpression.AggregationBuffer agg) throws HiveException
assignRowColumn
in class VectorAggregateExpression
HiveException
Copyright © 2022 The Apache Software Foundation. All rights reserved.