public class VectorPTFDesc extends AbstractVectorDesc
Modifier and Type | Class and Description |
---|---|
static class |
VectorPTFDesc.SupportedFunctionType |
Modifier and Type | Field and Description |
---|---|
static List<String> |
supportedFunctionNames |
static HashMap<String,VectorPTFDesc.SupportedFunctionType> |
supportedFunctionsMap |
Constructor and Description |
---|
VectorPTFDesc() |
clone, getVectorOpClass, setVectorOp
public static HashMap<String,VectorPTFDesc.SupportedFunctionType> supportedFunctionsMap
public static VectorPTFEvaluatorBase getEvaluator(VectorPTFDesc.SupportedFunctionType functionType, WindowFrameDef windowFrameDef, org.apache.hadoop.hive.ql.exec.vector.ColumnVector.Type columnVectorType, VectorExpression inputVectorExpression, int outputColumnNum)
public static VectorPTFEvaluatorBase[] getEvaluators(VectorPTFDesc vectorPTFDesc, VectorPTFInfo vectorPTFInfo)
public static int[] getStreamingEvaluatorNums(VectorPTFEvaluatorBase[] evaluators)
public TypeInfo[] getReducerBatchTypeInfos()
public void setReducerBatchTypeInfos(TypeInfo[] reducerBatchTypeInfos)
public boolean getIsPartitionOrderBy()
public void setIsPartitionOrderBy(boolean isPartitionOrderBy)
public String[] getEvaluatorFunctionNames()
public void setEvaluatorFunctionNames(String[] evaluatorFunctionNames)
public WindowFrameDef[] getEvaluatorWindowFrameDefs()
public void setEvaluatorWindowFrameDefs(WindowFrameDef[] evaluatorWindowFrameDefs)
public List<ExprNodeDesc>[] getEvaluatorInputExprNodeDescLists()
public void setEvaluatorInputExprNodeDescLists(List<ExprNodeDesc>[] evaluatorInputExprNodeDescLists)
public ExprNodeDesc[] getOrderExprNodeDescs()
public void setOrderExprNodeDescs(ExprNodeDesc[] orderExprNodeDescs)
public ExprNodeDesc[] getPartitionExprNodeDescs()
public void setPartitionExprNodeDescs(ExprNodeDesc[] partitionExprNodeDescs)
public String[] getOutputColumnNames()
public void setOutputColumnNames(String[] outputColumnNames)
public TypeInfo[] getOutputTypeInfos()
public void setOutputTypeInfos(TypeInfo[] outputTypeInfos)
public void setVectorPTFInfo(VectorPTFInfo vectorPTFInfo)
public VectorPTFInfo getVectorPTFInfo()
public void setVectorizedPTFMaxMemoryBufferingBatchCount(int vectorizedPTFMaxMemoryBufferingBatchCount)
public int getVectorizedPTFMaxMemoryBufferingBatchCount()
Copyright © 2022 The Apache Software Foundation. All rights reserved.