public class VectorPTFGroupBatches extends Object
Constructor and Description |
---|
VectorPTFGroupBatches(org.apache.hadoop.conf.Configuration hconf,
int vectorizedPTFMaxMemoryBufferingBatchCount) |
Modifier and Type | Method and Description |
---|---|
void |
bufferGroupBatch(org.apache.hadoop.hive.ql.exec.vector.VectorizedRowBatch batch) |
void |
evaluateGroupBatch(org.apache.hadoop.hive.ql.exec.vector.VectorizedRowBatch batch,
boolean isLastGroupBatch) |
void |
evaluateStreamingGroupBatch(org.apache.hadoop.hive.ql.exec.vector.VectorizedRowBatch batch,
boolean isLastGroupBatch) |
void |
fillGroupResultsAndForward(VectorPTFOperator vecPTFOperator,
org.apache.hadoop.hive.ql.exec.vector.VectorizedRowBatch lastBatch) |
void |
init(TypeInfo[] reducerBatchTypeInfos,
VectorPTFEvaluatorBase[] evaluators,
int[] outputProjectionColumnMap,
TypeInfo[] outputTypeInfos,
int[] keyInputColumnMap,
int[] nonKeyInputColumnMap,
int[] streamingEvaluatorNums,
org.apache.hadoop.hive.ql.exec.vector.VectorizedRowBatch overflowBatch) |
void |
resetEvaluators() |
public VectorPTFGroupBatches(org.apache.hadoop.conf.Configuration hconf, int vectorizedPTFMaxMemoryBufferingBatchCount)
public void init(TypeInfo[] reducerBatchTypeInfos, VectorPTFEvaluatorBase[] evaluators, int[] outputProjectionColumnMap, TypeInfo[] outputTypeInfos, int[] keyInputColumnMap, int[] nonKeyInputColumnMap, int[] streamingEvaluatorNums, org.apache.hadoop.hive.ql.exec.vector.VectorizedRowBatch overflowBatch)
public void evaluateStreamingGroupBatch(org.apache.hadoop.hive.ql.exec.vector.VectorizedRowBatch batch, boolean isLastGroupBatch) throws HiveException
HiveException
public void evaluateGroupBatch(org.apache.hadoop.hive.ql.exec.vector.VectorizedRowBatch batch, boolean isLastGroupBatch) throws HiveException
HiveException
public void fillGroupResultsAndForward(VectorPTFOperator vecPTFOperator, org.apache.hadoop.hive.ql.exec.vector.VectorizedRowBatch lastBatch) throws HiveException
HiveException
public void resetEvaluators()
public void bufferGroupBatch(org.apache.hadoop.hive.ql.exec.vector.VectorizedRowBatch batch) throws HiveException
HiveException
Copyright © 2022 The Apache Software Foundation. All rights reserved.