public class VectorPTFEvaluatorDoubleLastValue extends VectorPTFEvaluatorBase
Modifier and Type | Field and Description |
---|---|
protected boolean |
isGroupResultNull |
protected double |
lastValue |
inputColumnNum, LOG, outputColumnNum
Constructor and Description |
---|
VectorPTFEvaluatorDoubleLastValue(WindowFrameDef windowFrameDef,
VectorExpression inputVecExpr,
int outputColumnNum) |
Modifier and Type | Method and Description |
---|---|
void |
evaluateGroupBatch(VectorizedRowBatch batch) |
Object |
getGroupResult() |
ColumnVector.Type |
getResultColumnVectorType() |
boolean |
isCacheableForRange()
Whether the results calculated by this evaluator are eligible for caching by PTFValueCache.
|
boolean |
isGroupResultNull() |
void |
resetEvaluator() |
boolean |
streamsResult() |
canRunOptimizedCalculation, doLastBatchWork, evaluateInputExpr, getNullsLast, getOutputColumnNum, mapCustomColumns, onPartitionEnd, onResultCalculated, runOnRange, setNullsLast
protected boolean isGroupResultNull
protected double lastValue
public VectorPTFEvaluatorDoubleLastValue(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
public boolean isCacheableForRange()
VectorPTFEvaluatorBase
isCacheableForRange
in class VectorPTFEvaluatorBase
Copyright © 2022 The Apache Software Foundation. All rights reserved.