public class VectorPTFEvaluatorDecimalLastValue extends VectorPTFEvaluatorBase
Modifier and Type | Field and Description |
---|---|
protected boolean |
isGroupResultNull |
protected org.apache.hadoop.hive.serde2.io.HiveDecimalWritable |
lastValue |
inputColumnNum, outputColumnNum, windowFrameDef
Constructor and Description |
---|
VectorPTFEvaluatorDecimalLastValue(WindowFrameDef windowFrameDef,
VectorExpression inputVecExpr,
int outputColumnNum) |
Modifier and Type | Method and Description |
---|---|
void |
evaluateGroupBatch(org.apache.hadoop.hive.ql.exec.vector.VectorizedRowBatch batch,
boolean isLastGroupBatch) |
org.apache.hadoop.hive.serde2.io.HiveDecimalWritable |
getDecimalGroupResult() |
org.apache.hadoop.hive.ql.exec.vector.ColumnVector.Type |
getResultColumnVectorType() |
boolean |
isGroupResultNull() |
void |
resetEvaluator() |
evaluateInputExpr, getDoubleGroupResult, getLongGroupResult, getOutputColumnNum, streamsResult
protected boolean isGroupResultNull
protected org.apache.hadoop.hive.serde2.io.HiveDecimalWritable lastValue
public VectorPTFEvaluatorDecimalLastValue(WindowFrameDef windowFrameDef, VectorExpression inputVecExpr, int outputColumnNum)
public void evaluateGroupBatch(org.apache.hadoop.hive.ql.exec.vector.VectorizedRowBatch batch, boolean isLastGroupBatch) throws HiveException
evaluateGroupBatch
in class VectorPTFEvaluatorBase
HiveException
public boolean isGroupResultNull()
isGroupResultNull
in class VectorPTFEvaluatorBase
public org.apache.hadoop.hive.ql.exec.vector.ColumnVector.Type getResultColumnVectorType()
getResultColumnVectorType
in class VectorPTFEvaluatorBase
public org.apache.hadoop.hive.serde2.io.HiveDecimalWritable getDecimalGroupResult()
getDecimalGroupResult
in class VectorPTFEvaluatorBase
public void resetEvaluator()
resetEvaluator
in class VectorPTFEvaluatorBase
Copyright © 2019 The Apache Software Foundation. All rights reserved.