public abstract class VectorExpression extends Object implements Serializable
Modifier and Type | Field and Description |
---|---|
protected VectorExpression[] |
childExpressions
Child expressions for parameters -- but only those that need to be computed.
|
protected org.apache.hadoop.hive.common.type.DataTypePhysicalVariation[] |
inputDataTypePhysicalVariations |
protected TypeInfo[] |
inputTypeInfos
ALL input parameter type information is here including those for (non-computed) columns and
scalar values.
|
protected int |
outputColumnNum
Output column number and type information of the vector expression.
|
protected org.apache.hadoop.hive.common.type.DataTypePhysicalVariation |
outputDataTypePhysicalVariation |
protected TypeInfo |
outputTypeInfo |
Constructor and Description |
---|
VectorExpression() |
VectorExpression(int outputColumnNum) |
Modifier and Type | Method and Description |
---|---|
static String |
displayArrayOfUtf8ByteArrays(byte[][] arrayOfByteArrays) |
static String |
displayUtf8Bytes(byte[] bytes) |
static void |
doTransientInit(VectorExpression vecExpr) |
static void |
doTransientInit(VectorExpression[] vecExprs) |
abstract void |
evaluate(org.apache.hadoop.hive.ql.exec.vector.VectorizedRowBatch batch)
This is the primary method to implement expression logic.
|
protected void |
evaluateChildren(org.apache.hadoop.hive.ql.exec.vector.VectorizedRowBatch vrg)
Evaluate the child expressions on the given input batch.
|
VectorExpression[] |
getChildExpressions() |
protected String |
getColumnParamString(int typeNum,
int columnNum) |
abstract VectorExpressionDescriptor.Descriptor |
getDescriptor() |
protected String |
getDoubleValueParamString(int typeNum,
double value) |
org.apache.hadoop.hive.common.type.DataTypePhysicalVariation[] |
getInputDataTypePhysicalVariations() |
TypeInfo[] |
getInputTypeInfos() |
protected String |
getLongValueParamString(int typeNum,
long value) |
int |
getOutputColumnNum()
Returns the index of the output column in the array
of column vectors.
|
org.apache.hadoop.hive.ql.exec.vector.ColumnVector.Type |
getOutputColumnVectorType() |
org.apache.hadoop.hive.common.type.DataTypePhysicalVariation |
getOutputDataTypePhysicalVariation() |
TypeInfo |
getOutputTypeInfo()
Returns type of the output column.
|
protected String |
getParamTypeString(int typeNum) |
static String |
getTypeName(TypeInfo typeInfo,
org.apache.hadoop.hive.common.type.DataTypePhysicalVariation dataTypePhysicalVariation) |
void |
init(org.apache.hadoop.conf.Configuration conf) |
void |
setChildExpressions(VectorExpression[] childExpressions)
Initialize the child expressions.
|
void |
setInputDataTypePhysicalVariations(org.apache.hadoop.hive.common.type.DataTypePhysicalVariation... inputDataTypePhysicalVariations) |
void |
setInputTypeInfos(TypeInfo... inputTypeInfos) |
void |
setOutputDataTypePhysicalVariation(org.apache.hadoop.hive.common.type.DataTypePhysicalVariation outputDataTypePhysicalVariation)
Set data type read variation.
|
void |
setOutputTypeInfo(TypeInfo outputTypeInfo)
Set type of the output column.
|
boolean |
supportsCheckedExecution()
A vector expression which implements a checked execution to account for overflow handling
should override this method and return true.
|
String |
toString() |
void |
transientInit() |
abstract String |
vectorExpressionParameters() |
protected VectorExpression[] childExpressions
protected TypeInfo[] inputTypeInfos
protected org.apache.hadoop.hive.common.type.DataTypePhysicalVariation[] inputDataTypePhysicalVariations
protected final int outputColumnNum
protected TypeInfo outputTypeInfo
protected org.apache.hadoop.hive.common.type.DataTypePhysicalVariation outputDataTypePhysicalVariation
public VectorExpression()
public VectorExpression(int outputColumnNum)
public void setChildExpressions(VectorExpression[] childExpressions)
public VectorExpression[] getChildExpressions()
public void setInputTypeInfos(TypeInfo... inputTypeInfos)
public TypeInfo[] getInputTypeInfos()
public void setInputDataTypePhysicalVariations(org.apache.hadoop.hive.common.type.DataTypePhysicalVariation... inputDataTypePhysicalVariations)
public org.apache.hadoop.hive.common.type.DataTypePhysicalVariation[] getInputDataTypePhysicalVariations()
public abstract String vectorExpressionParameters()
public void transientInit() throws HiveException
HiveException
public static void doTransientInit(VectorExpression vecExpr) throws HiveException
HiveException
public static void doTransientInit(VectorExpression[] vecExprs) throws HiveException
HiveException
public int getOutputColumnNum()
public TypeInfo getOutputTypeInfo()
public void setOutputTypeInfo(TypeInfo outputTypeInfo)
public void setOutputDataTypePhysicalVariation(org.apache.hadoop.hive.common.type.DataTypePhysicalVariation outputDataTypePhysicalVariation)
public org.apache.hadoop.hive.common.type.DataTypePhysicalVariation getOutputDataTypePhysicalVariation()
public org.apache.hadoop.hive.ql.exec.vector.ColumnVector.Type getOutputColumnVectorType() throws HiveException
HiveException
public abstract void evaluate(org.apache.hadoop.hive.ql.exec.vector.VectorizedRowBatch batch) throws HiveException
batch
- HiveException
public void init(org.apache.hadoop.conf.Configuration conf)
public abstract VectorExpressionDescriptor.Descriptor getDescriptor()
protected final void evaluateChildren(org.apache.hadoop.hive.ql.exec.vector.VectorizedRowBatch vrg) throws HiveException
vrg
- VectorizedRowBatch
HiveException
protected String getColumnParamString(int typeNum, int columnNum)
protected String getLongValueParamString(int typeNum, long value)
protected String getDoubleValueParamString(int typeNum, double value)
protected String getParamTypeString(int typeNum)
public static String getTypeName(TypeInfo typeInfo, org.apache.hadoop.hive.common.type.DataTypePhysicalVariation dataTypePhysicalVariation)
public boolean supportsCheckedExecution()
public static String displayUtf8Bytes(byte[] bytes)
public static String displayArrayOfUtf8ByteArrays(byte[][] arrayOfByteArrays)
Copyright © 2022 The Apache Software Foundation. All rights reserved.