org.apache.hadoop.hive.ql.exec.vector

Class VectorizationContext

java.lang.Object

org.apache.hadoop.hive.ql.exec.vector.VectorizationContext

public class VectorizationContext
extends Object

Context class for vectorization execution. Main role is to map column names to column indices and serves as a factory class for building vectorized expressions out of descriptors.

Field Summary

Fields

Modifier and Type	Field and Description
static Pattern	charTypePattern
static Pattern	charVarcharTypePattern
static Pattern	decimalTypePattern
static Pattern	varcharTypePattern

Constructor Summary

Constructors

Constructor and Description
VectorizationContext(String contextName)
VectorizationContext(String contextName, List<String> initialColumnNames)
VectorizationContext(String contextName, VectorizationContext vContext)

Method Summary

Methods

Modifier and Type	Method and Description
void	addInitialColumn(String columnName)
void	addProjectionColumn(String columnName, int vectorBatchColIndex)
int	allocateScratchColumn(String hiveTypeName)
static String	arg0Type(ExprNodeGenericFuncDesc expr)
int[]	currentScratchColumns()
void	finishedAddingInitialColumns()
int	firstOutputColumnIndex()
VectorAggregateExpression	getAggregatorExpression(AggregationDesc desc, boolean isReduce)
static ColumnVector.Type	getColumnVectorTypeFromTypeInfo(TypeInfo typeInfo)
protected int	getInputColumnIndex(ExprNodeColumnDesc colExpr)
protected int	getInputColumnIndex(String name)
List<Integer>	getProjectedColumns()
Map<String,Integer>	getProjectionColumnMap()
List<String>	getProjectionColumnNames()
Map<Integer,String>	getScratchColumnTypeMap()
VectorExpression	getVectorExpression(ExprNodeDesc exprDesc)
VectorExpression	getVectorExpression(ExprNodeDesc exprDesc, VectorExpressionDescriptor.Mode mode) Returns a vector expression for a given expression description.
VectorExpression[]	getVectorExpressions(List<ExprNodeDesc> exprNodes)
VectorExpression[]	getVectorExpressions(List<ExprNodeDesc> exprNodes, VectorExpressionDescriptor.Mode mode)
static boolean	isCastToFloatFamily(Class<? extends UDF> udfClass)
static boolean	isCastToIntFamily(Class<? extends UDF> udfClass)
static boolean	isCustomUDF(ExprNodeGenericFuncDesc expr)
static boolean	isDateFamily(String resultType)
static boolean	isDatetimeFamily(String resultType)
static boolean	isDecimalFamily(String colType)
static boolean	isFloatFamily(String resultType)
static boolean	isIntervalDayTimeFamily(String resultType)
static boolean	isIntervalYearMonthFamily(String resultType)
static boolean	isIntFamily(String resultType)
static boolean	isNonVectorizedPathUDF(ExprNodeGenericFuncDesc expr)
static boolean	isStringFamily(String resultType)
static boolean	isTimestampFamily(String resultType)
static String	mapTypeNameSynonyms(String typeName)
void	resetProjectionColumns()
String	toString()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Detail

decimalTypePattern

public static final Pattern decimalTypePattern

charTypePattern

public static final Pattern charTypePattern

varcharTypePattern

public static final Pattern varcharTypePattern

charVarcharTypePattern

public static final Pattern charVarcharTypePattern

Constructor Detail

VectorizationContext

public VectorizationContext(String contextName,
                    List<String> initialColumnNames)

VectorizationContext

public VectorizationContext(String contextName)

VectorizationContext

public VectorizationContext(String contextName,
                    VectorizationContext vContext)

Method Detail

addInitialColumn

public void addInitialColumn(String columnName)

finishedAddingInitialColumns

public void finishedAddingInitialColumns()

resetProjectionColumns

public void resetProjectionColumns()

addProjectionColumn

public void addProjectionColumn(String columnName,
                       int vectorBatchColIndex)

getProjectedColumns

public List<Integer> getProjectedColumns()

getProjectionColumnNames

public List<String> getProjectionColumnNames()

getProjectionColumnMap

public Map<String,Integer> getProjectionColumnMap()

getInputColumnIndex

protected int getInputColumnIndex(String name)
                           throws HiveException

Throws:

HiveException

getInputColumnIndex

protected int getInputColumnIndex(ExprNodeColumnDesc colExpr)
                           throws HiveException

Throws:

HiveException

allocateScratchColumn

public int allocateScratchColumn(String hiveTypeName)

currentScratchColumns

public int[] currentScratchColumns()

getVectorExpressions

public VectorExpression[] getVectorExpressions(List<ExprNodeDesc> exprNodes)
                                        throws HiveException

Throws:

HiveException

getVectorExpressions

public VectorExpression[] getVectorExpressions(List<ExprNodeDesc> exprNodes,
                                      VectorExpressionDescriptor.Mode mode)
                                        throws HiveException

Throws:

HiveException

getVectorExpression

public VectorExpression getVectorExpression(ExprNodeDesc exprDesc)
                                     throws HiveException

Throws:

HiveException

getVectorExpression

public VectorExpression getVectorExpression(ExprNodeDesc exprDesc,
                                   VectorExpressionDescriptor.Mode mode)
                                     throws HiveException

Returns a vector expression for a given expression description.

Parameters:

exprDesc, - Expression description

mode -

Returns:

VectorExpression

Throws:

HiveException

isNonVectorizedPathUDF

public static boolean isNonVectorizedPathUDF(ExprNodeGenericFuncDesc expr)

isCastToIntFamily

public static boolean isCastToIntFamily(Class<? extends UDF> udfClass)

isCastToFloatFamily

public static boolean isCastToFloatFamily(Class<? extends UDF> udfClass)

arg0Type

public static String arg0Type(ExprNodeGenericFuncDesc expr)

isCustomUDF

public static boolean isCustomUDF(ExprNodeGenericFuncDesc expr)

isStringFamily

public static boolean isStringFamily(String resultType)

isDatetimeFamily

public static boolean isDatetimeFamily(String resultType)

isTimestampFamily

public static boolean isTimestampFamily(String resultType)

isDateFamily

public static boolean isDateFamily(String resultType)

isIntervalYearMonthFamily

public static boolean isIntervalYearMonthFamily(String resultType)

isIntervalDayTimeFamily

public static boolean isIntervalDayTimeFamily(String resultType)

isFloatFamily

public static boolean isFloatFamily(String resultType)

isIntFamily

public static boolean isIntFamily(String resultType)

isDecimalFamily

public static boolean isDecimalFamily(String colType)

mapTypeNameSynonyms

public static String mapTypeNameSynonyms(String typeName)

getColumnVectorTypeFromTypeInfo

public static ColumnVector.Type getColumnVectorTypeFromTypeInfo(TypeInfo typeInfo)
                                                         throws HiveException

Throws:

HiveException

getAggregatorExpression

public VectorAggregateExpression getAggregatorExpression(AggregationDesc desc,
                                                boolean isReduce)
                                                  throws HiveException

Throws:

HiveException

firstOutputColumnIndex

public int firstOutputColumnIndex()

getScratchColumnTypeMap

public Map<Integer,String> getScratchColumnTypeMap()

toString

public String toString()

Overrides:

toString in class Object