public class VectorHashKeyWrapperBatch extends VectorColumnSetInfo
columnTypeSpecificIndices, columnVectorTypes, decimalIndices, doubleIndices, intervalDayTimeIndices, keyCount, longIndices, stringIndices, timestampIndices, typeInfos
Constructor and Description |
---|
VectorHashKeyWrapperBatch(int keyCount) |
Modifier and Type | Method and Description |
---|---|
VectorHashKeyWrapper |
allocateKeyWrapper() |
void |
assignRowColumn(org.apache.hadoop.hive.ql.exec.vector.VectorizedRowBatch batch,
int batchIndex,
int keyIndex,
VectorHashKeyWrapper kw) |
static VectorHashKeyWrapperBatch |
compileKeyWrapperBatch(VectorExpression[] keyExpressions) |
static VectorHashKeyWrapperBatch |
compileKeyWrapperBatch(VectorExpression[] keyExpressions,
TypeInfo[] typeInfos)
Prepares a VectorHashKeyWrapperBatch to work for a specific set of keys.
|
void |
evaluateBatch(org.apache.hadoop.hive.ql.exec.vector.VectorizedRowBatch batch)
Processes a batch:
Evaluates each key vector expression.
Copies out each key's primitive values into the key wrappers
computes the hashcode of the key wrappers
|
void |
evaluateBatchGroupingSets(org.apache.hadoop.hive.ql.exec.vector.VectorizedRowBatch batch,
boolean[] groupingSetsOverrideIsNulls) |
int |
getKeysFixedSize()
Returns the compiled fixed size for the key wrappers.
|
int |
getVariableSize(int batchSize) |
VectorHashKeyWrapper[] |
getVectorHashKeyWrappers()
Accessor for the batch-sized array of key wrappers.
|
Object |
getWritableKeyValue(VectorHashKeyWrapper kw,
int keyIndex,
VectorExpressionWriter keyOutputWriter)
Get the row-mode writable object value of a key from a key wrapper
|
void |
setLongValue(VectorHashKeyWrapper kw,
int keyIndex,
Long value) |
addKey, finishAdding
public int getKeysFixedSize()
public VectorHashKeyWrapper[] getVectorHashKeyWrappers()
public void evaluateBatch(org.apache.hadoop.hive.ql.exec.vector.VectorizedRowBatch batch) throws HiveException
batch
- HiveException
public void evaluateBatchGroupingSets(org.apache.hadoop.hive.ql.exec.vector.VectorizedRowBatch batch, boolean[] groupingSetsOverrideIsNulls) throws HiveException
HiveException
public static VectorHashKeyWrapperBatch compileKeyWrapperBatch(VectorExpression[] keyExpressions) throws HiveException
HiveException
public static VectorHashKeyWrapperBatch compileKeyWrapperBatch(VectorExpression[] keyExpressions, TypeInfo[] typeInfos) throws HiveException
HiveException
public VectorHashKeyWrapper allocateKeyWrapper()
public Object getWritableKeyValue(VectorHashKeyWrapper kw, int keyIndex, VectorExpressionWriter keyOutputWriter) throws HiveException
keyOutputWriter
- HiveException
public void setLongValue(VectorHashKeyWrapper kw, int keyIndex, Long value) throws HiveException
HiveException
public void assignRowColumn(org.apache.hadoop.hive.ql.exec.vector.VectorizedRowBatch batch, int batchIndex, int keyIndex, VectorHashKeyWrapper kw) throws HiveException
HiveException
public int getVariableSize(int batchSize)
Copyright © 2022 The Apache Software Foundation. All rights reserved.