public class VectorUDAFBloomFilter extends VectorAggregateExpression
Modifier and Type | Class and Description |
---|---|
static class |
VectorUDAFBloomFilter.ValueProcessorBytes |
static class |
VectorUDAFBloomFilter.ValueProcessorDecimal |
static class |
VectorUDAFBloomFilter.ValueProcessorDouble |
static class |
VectorUDAFBloomFilter.ValueProcessorLong |
static class |
VectorUDAFBloomFilter.ValueProcessorTimestamp |
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 |
---|
VectorUDAFBloomFilter() |
VectorUDAFBloomFilter(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() |
long |
getExpectedEntries() |
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) |
void |
setExpectedEntries(long expectedEntries) |
getInputExpression, getOutputDataTypePhysicalVariation, getOutputTypeInfo, hasVariableSize, toString
public VectorUDAFBloomFilter()
public VectorUDAFBloomFilter(VectorAggregationDesc vecAggrDesc)
public VectorAggregateExpression.AggregationBuffer getNewAggregationBuffer() throws HiveException
getNewAggregationBuffer
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 void aggregateInputSelection(VectorAggregationBufferRow[] aggregationBufferSets, int aggregateIndex, org.apache.hadoop.hive.ql.exec.vector.VectorizedRowBatch batch) throws HiveException
aggregateInputSelection
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 long getExpectedEntries()
public void setExpectedEntries(long expectedEntries)
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.