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 |
---|---|
VectorHashKeyWrapperBase |
allocateKeyWrapper() |
void |
assignRowColumn(VectorizedRowBatch batch,
int batchIndex,
int keyIndex,
VectorHashKeyWrapperBase 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(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(VectorizedRowBatch batch,
boolean[] groupingSetsOverrideIsNulls) |
Comparator<VectorHashKeyWrapperBase> |
getComparator(String columnSortOrder,
String nullOrder) |
int |
getKeysFixedSize()
Returns the compiled fixed size for the key wrappers.
|
int |
getVariableSize(int batchSize) |
VectorHashKeyWrapperBase[] |
getVectorHashKeyWrappers()
Accessor for the batch-sized array of key wrappers.
|
Object |
getWritableKeyValue(VectorHashKeyWrapperBase kw,
int keyIndex,
VectorExpressionWriter keyOutputWriter)
Get the row-mode writable object value of a key from a key wrapper
|
void |
setLongValue(VectorHashKeyWrapperBase kw,
int keyIndex,
Long value) |
addKey, finishAdding
public int getKeysFixedSize()
public VectorHashKeyWrapperBase[] getVectorHashKeyWrappers()
public void evaluateBatch(VectorizedRowBatch batch) throws HiveException
batch
- HiveException
public void evaluateBatchGroupingSets(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 VectorHashKeyWrapperBase allocateKeyWrapper()
public Object getWritableKeyValue(VectorHashKeyWrapperBase kw, int keyIndex, VectorExpressionWriter keyOutputWriter) throws HiveException
keyOutputWriter
- HiveException
public void setLongValue(VectorHashKeyWrapperBase kw, int keyIndex, Long value) throws HiveException
HiveException
public void assignRowColumn(VectorizedRowBatch batch, int batchIndex, int keyIndex, VectorHashKeyWrapperBase kw) throws HiveException
HiveException
public int getVariableSize(int batchSize)
public Comparator<VectorHashKeyWrapperBase> getComparator(String columnSortOrder, String nullOrder)
Copyright © 2023 The Apache Software Foundation. All rights reserved.