public class VectorHashKeyWrapperBatch extends VectorColumnSetInfo
columnTypeSpecificIndices, columnVectorTypes, decimalIndices, doubleIndices, intervalDayTimeIndices, keyCount, longIndices, stringIndices, timestampIndices
Constructor and Description |
---|
VectorHashKeyWrapperBatch(int keyCount) |
Modifier and Type | Method and Description |
---|---|
VectorHashKeyWrapper |
allocateKeyWrapper() |
static VectorHashKeyWrapperBatch |
compileKeyWrapperBatch(VectorExpression[] keyExpressions) |
static VectorHashKeyWrapperBatch |
compileKeyWrapperBatch(VectorExpression[] keyExpressions,
org.apache.hadoop.hive.ql.exec.vector.ColumnVector.Type[] columnVectorTypes)
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
|
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, org.apache.hadoop.hive.ql.exec.vector.ColumnVector.Type[] columnVectorTypes) throws HiveException
HiveException
public VectorHashKeyWrapper allocateKeyWrapper()
public Object getWritableKeyValue(VectorHashKeyWrapper kw, int keyIndex, VectorExpressionWriter keyOutputWriter) throws HiveException
keyOutputWriter
- HiveException
public int getVariableSize(int batchSize)
Copyright © 2021 The Apache Software Foundation. All rights reserved.