public class VectorPTFEvaluatorRowNumber extends VectorPTFEvaluatorBase
inputColumnNum, LOG, outputColumnNum
Constructor and Description |
---|
VectorPTFEvaluatorRowNumber(WindowFrameDef windowFrameDef,
VectorExpression inputVecExpr,
int outputColumnNum) |
Modifier and Type | Method and Description |
---|---|
void |
evaluateGroupBatch(VectorizedRowBatch batch) |
Object |
getGroupResult() |
ColumnVector.Type |
getResultColumnVectorType() |
boolean |
isGroupResultNull() |
void |
resetEvaluator() |
boolean |
streamsResult() |
canRunOptimizedCalculation, doLastBatchWork, evaluateInputExpr, getNullsLast, getOutputColumnNum, isCacheableForRange, mapCustomColumns, onPartitionEnd, onResultCalculated, runOnRange, setNullsLast
public VectorPTFEvaluatorRowNumber(WindowFrameDef windowFrameDef, VectorExpression inputVecExpr, int outputColumnNum)
public void evaluateGroupBatch(VectorizedRowBatch batch) throws HiveException
evaluateGroupBatch
in class VectorPTFEvaluatorBase
HiveException
public boolean streamsResult()
streamsResult
in class VectorPTFEvaluatorBase
public boolean isGroupResultNull()
isGroupResultNull
in class VectorPTFEvaluatorBase
public Object getGroupResult()
getGroupResult
in class VectorPTFEvaluatorBase
public ColumnVector.Type getResultColumnVectorType()
getResultColumnVectorType
in class VectorPTFEvaluatorBase
public void resetEvaluator()
resetEvaluator
in class VectorPTFEvaluatorBase
Copyright © 2022 The Apache Software Foundation. All rights reserved.