public class VectorPTFEvaluatorLongAvg extends VectorPTFEvaluatorAbstractAvg<Long>
Modifier and Type | Field and Description |
---|---|
protected double |
avg |
isGroupResultNull, nonNullGroupCount, previousCount, previousRange, previousSum, sum
inputColumnNum, LOG, outputColumnNum
Constructor and Description |
---|
VectorPTFEvaluatorLongAvg(WindowFrameDef windowFrameDef,
VectorExpression inputVecExpr,
int outputColumnNum) |
Modifier and Type | Method and Description |
---|---|
protected Long |
computeValue(Long number) |
protected Double |
divide(Long number,
long divisor) |
void |
doLastBatchWork() |
void |
evaluateGroupBatch(VectorizedRowBatch batch) |
Object |
getGroupResult() |
ColumnVector.Type |
getResultColumnVectorType() |
protected Long |
minus(Long number1,
Long number2) |
protected Long |
plus(Long number1,
Long number2) |
void |
resetEvaluator() |
canRunOptimizedCalculation, isGroupResultNull, onPartitionEnd, onResultCalculated, runOnRange, streamsResult
evaluateInputExpr, getNullsLast, getOutputColumnNum, isCacheableForRange, mapCustomColumns, setNullsLast
public VectorPTFEvaluatorLongAvg(WindowFrameDef windowFrameDef, VectorExpression inputVecExpr, int outputColumnNum)
public void evaluateGroupBatch(VectorizedRowBatch batch) throws HiveException
evaluateGroupBatch
in class VectorPTFEvaluatorBase
HiveException
public void doLastBatchWork()
doLastBatchWork
in class VectorPTFEvaluatorBase
public ColumnVector.Type getResultColumnVectorType()
getResultColumnVectorType
in class VectorPTFEvaluatorBase
public Object getGroupResult()
getGroupResult
in class VectorPTFEvaluatorBase
protected Long computeValue(Long number)
computeValue
in class VectorPTFEvaluatorAbstractAvg<Long>
protected Long plus(Long number1, Long number2)
plus
in class VectorPTFEvaluatorAbstractAvg<Long>
protected Long minus(Long number1, Long number2)
minus
in class VectorPTFEvaluatorAbstractAvg<Long>
protected Double divide(Long number, long divisor)
divide
in class VectorPTFEvaluatorAbstractAvg<Long>
public void resetEvaluator()
resetEvaluator
in class VectorPTFEvaluatorBase
Copyright © 2022 The Apache Software Foundation. All rights reserved.