public class Vectorizer extends Object implements PhysicalPlanResolver
Modifier and Type | Class and Description |
---|---|
static class |
Vectorizer.VectorizationEnabledOverride |
class |
Vectorizer.VectorizerCannotVectorizeException |
Modifier and Type | Field and Description |
---|---|
protected static org.slf4j.Logger |
LOG |
static com.google.common.collect.ImmutableSet<VirtualColumn> |
vectorizableVirtualColumns |
Constructor and Description |
---|
Vectorizer() |
Modifier and Type | Method and Description |
---|---|
static String |
getValidateDataTypeErrorMsg(String type,
VectorExpressionDescriptor.Mode mode,
boolean allowComplex,
boolean isVectorizationComplexTypesEnabled) |
static String |
getValidateDataTypeErrorMsg(String type,
VectorExpressionDescriptor.Mode mode,
boolean allowComplex,
boolean isVectorizationComplexTypesEnabled,
boolean allowVoidProjection) |
static boolean |
onExpressionHasNullSafes(MapJoinDesc desc) |
PhysicalContext |
resolve(PhysicalContext physicalContext)
All physical plan resolvers have to implement this entry method.
|
void |
testSetCurrentBaseWork(BaseWork testBaseWork) |
Operator<? extends OperatorDesc> |
validateAndVectorizeOperator(Operator<? extends OperatorDesc> op,
VectorizationContext vContext,
boolean isReduce,
boolean isTezOrSpark,
org.apache.hadoop.hive.ql.optimizer.physical.Vectorizer.VectorTaskColumnInfo vectorTaskColumnInfo) |
static boolean |
validateDataType(String type,
VectorExpressionDescriptor.Mode mode,
boolean allowComplex) |
static boolean |
validateDataType(String type,
VectorExpressionDescriptor.Mode mode,
boolean allowComplex,
boolean allowVoidProjection) |
static Operator<? extends OperatorDesc> |
vectorizeFilterOperator(Operator<? extends OperatorDesc> filterOp,
VectorizationContext vContext,
VectorFilterDesc vectorFilterDesc) |
static Operator<? extends OperatorDesc> |
vectorizeGroupByOperator(Operator<? extends OperatorDesc> groupByOp,
VectorizationContext vContext,
VectorGroupByDesc vectorGroupByDesc) |
Operator<? extends OperatorDesc> |
vectorizeOperator(Operator<? extends OperatorDesc> op,
VectorizationContext vContext,
boolean isReduce,
boolean isTezOrSpark,
org.apache.hadoop.hive.ql.optimizer.physical.Vectorizer.VectorTaskColumnInfo vectorTaskColumnInfo) |
static Operator<? extends OperatorDesc> |
vectorizePTFOperator(Operator<? extends OperatorDesc> ptfOp,
VectorizationContext vContext,
VectorPTFDesc vectorPTFDesc) |
static Operator<? extends OperatorDesc> |
vectorizeSelectOperator(Operator<? extends OperatorDesc> selectOp,
VectorizationContext vContext,
VectorSelectDesc vectorSelectDesc) |
protected static final transient org.slf4j.Logger LOG
public static final com.google.common.collect.ImmutableSet<VirtualColumn> vectorizableVirtualColumns
public void testSetCurrentBaseWork(BaseWork testBaseWork)
public PhysicalContext resolve(PhysicalContext physicalContext) throws SemanticException
PhysicalPlanResolver
resolve
in interface PhysicalPlanResolver
SemanticException
public static boolean validateDataType(String type, VectorExpressionDescriptor.Mode mode, boolean allowComplex)
public static boolean validateDataType(String type, VectorExpressionDescriptor.Mode mode, boolean allowComplex, boolean allowVoidProjection)
public static String getValidateDataTypeErrorMsg(String type, VectorExpressionDescriptor.Mode mode, boolean allowComplex, boolean isVectorizationComplexTypesEnabled)
public static String getValidateDataTypeErrorMsg(String type, VectorExpressionDescriptor.Mode mode, boolean allowComplex, boolean isVectorizationComplexTypesEnabled, boolean allowVoidProjection)
public static boolean onExpressionHasNullSafes(MapJoinDesc desc)
public static Operator<? extends OperatorDesc> vectorizeFilterOperator(Operator<? extends OperatorDesc> filterOp, VectorizationContext vContext, VectorFilterDesc vectorFilterDesc) throws HiveException
HiveException
public static Operator<? extends OperatorDesc> vectorizeGroupByOperator(Operator<? extends OperatorDesc> groupByOp, VectorizationContext vContext, VectorGroupByDesc vectorGroupByDesc) throws HiveException
HiveException
public static Operator<? extends OperatorDesc> vectorizeSelectOperator(Operator<? extends OperatorDesc> selectOp, VectorizationContext vContext, VectorSelectDesc vectorSelectDesc) throws HiveException
HiveException
public static Operator<? extends OperatorDesc> vectorizePTFOperator(Operator<? extends OperatorDesc> ptfOp, VectorizationContext vContext, VectorPTFDesc vectorPTFDesc) throws HiveException
HiveException
public Operator<? extends OperatorDesc> vectorizeOperator(Operator<? extends OperatorDesc> op, VectorizationContext vContext, boolean isReduce, boolean isTezOrSpark, org.apache.hadoop.hive.ql.optimizer.physical.Vectorizer.VectorTaskColumnInfo vectorTaskColumnInfo) throws HiveException, Vectorizer.VectorizerCannotVectorizeException
public Operator<? extends OperatorDesc> validateAndVectorizeOperator(Operator<? extends OperatorDesc> op, VectorizationContext vContext, boolean isReduce, boolean isTezOrSpark, org.apache.hadoop.hive.ql.optimizer.physical.Vectorizer.VectorTaskColumnInfo vectorTaskColumnInfo) throws HiveException, Vectorizer.VectorizerCannotVectorizeException
Copyright © 2022 The Apache Software Foundation. All rights reserved.