public class VectorPTFEvaluatorStreamingLongAvg extends VectorPTFEvaluatorBase
Modifier and Type | Field and Description |
---|---|
protected double |
avg |
protected boolean |
isNull |
protected long |
sum |
inputColumnNum, LOG, outputColumnNum
Constructor and Description |
---|
VectorPTFEvaluatorStreamingLongAvg(WindowFrameDef windowFrameDef,
VectorExpression inputVecExpr,
int outputColumnNum) |
Modifier and Type | Method and Description |
---|---|
void |
evaluateGroupBatch(VectorizedRowBatch batch) |
ColumnVector.Type |
getResultColumnVectorType() |
void |
resetEvaluator() |
boolean |
streamsResult() |
canRunOptimizedCalculation, doLastBatchWork, evaluateInputExpr, getGroupResult, getNullsLast, getOutputColumnNum, isCacheableForRange, isGroupResultNull, mapCustomColumns, onPartitionEnd, onResultCalculated, runOnRange, setNullsLast
public VectorPTFEvaluatorStreamingLongAvg(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 ColumnVector.Type getResultColumnVectorType()
getResultColumnVectorType
in class VectorPTFEvaluatorBase
public void resetEvaluator()
resetEvaluator
in class VectorPTFEvaluatorBase
Copyright © 2022 The Apache Software Foundation. All rights reserved.