public class VectorPTFEvaluatorLongMin extends VectorPTFEvaluatorBase
Modifier and Type | Field and Description |
---|---|
protected boolean |
isGroupResultNull |
protected long |
min |
inputColumnNum, LOG, outputColumnNum
Constructor and Description |
---|
VectorPTFEvaluatorLongMin(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 VectorPTFEvaluatorLongMin(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 ColumnVector.Type getResultColumnVectorType()
getResultColumnVectorType
in class VectorPTFEvaluatorBase
public Object getGroupResult()
getGroupResult
in class VectorPTFEvaluatorBase
public void resetEvaluator()
resetEvaluator
in class VectorPTFEvaluatorBase
Copyright © 2023 The Apache Software Foundation. All rights reserved.