org.apache.hadoop.hive.ql.exec.vector

Class VectorHashKeyWrapperBatch

java.lang.Object

org.apache.hadoop.hive.ql.exec.vector.VectorColumnSetInfo

org.apache.hadoop.hive.ql.exec.vector.VectorHashKeyWrapperBatch

public class VectorHashKeyWrapperBatch
extends VectorColumnSetInfo

Class for handling vectorized hash map key wrappers. It evaluates the key columns in a row batch in a vectorized fashion. This class stores additional information about keys needed to evaluate and output the key values.

Field Summary

Fields inherited from class org.apache.hadoop.hive.ql.exec.vector.VectorColumnSetInfo

columnTypeSpecificIndices, columnVectorTypes, decimalIndices, doubleIndices, intervalDayTimeIndices, keyCount, longIndices, stringIndices, timestampIndices, typeInfos

Constructor Summary

Constructors

Constructor and Description
VectorHashKeyWrapperBatch(int keyCount)

Method Summary

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)

Methods inherited from class org.apache.hadoop.hive.ql.exec.vector.VectorColumnSetInfo

addKey, finishAdding

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

VectorHashKeyWrapperBatch

public VectorHashKeyWrapperBatch(int keyCount)

Method Detail

getKeysFixedSize

public int getKeysFixedSize()

Returns the compiled fixed size for the key wrappers.

Returns:

getVectorHashKeyWrappers

public VectorHashKeyWrapper[] getVectorHashKeyWrappers()

Accessor for the batch-sized array of key wrappers.

evaluateBatch

public void evaluateBatch(org.apache.hadoop.hive.ql.exec.vector.VectorizedRowBatch batch)
                   throws HiveException

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

Parameters:

batch -

Throws:

HiveException

evaluateBatchGroupingSets

public void evaluateBatchGroupingSets(org.apache.hadoop.hive.ql.exec.vector.VectorizedRowBatch batch,
                                      boolean[] groupingSetsOverrideIsNulls)
                               throws HiveException

Throws:

HiveException

compileKeyWrapperBatch

public static VectorHashKeyWrapperBatch compileKeyWrapperBatch(VectorExpression[] keyExpressions)
                                                        throws HiveException

Throws:

HiveException

compileKeyWrapperBatch

public static VectorHashKeyWrapperBatch compileKeyWrapperBatch(VectorExpression[] keyExpressions,
                                                               TypeInfo[] typeInfos)
                                                        throws HiveException

Prepares a VectorHashKeyWrapperBatch to work for a specific set of keys. Computes the fast access lookup indices, preallocates all needed internal arrays. This step is done only once per query, not once per batch. The information computed now will be used to generate proper individual VectorKeyHashWrapper objects.

Throws:

HiveException

allocateKeyWrapper

public VectorHashKeyWrapper allocateKeyWrapper()

getWritableKeyValue

public Object getWritableKeyValue(VectorHashKeyWrapper kw,
                                  int keyIndex,
                                  VectorExpressionWriter keyOutputWriter)
                           throws HiveException

Get the row-mode writable object value of a key from a key wrapper

Parameters:

keyOutputWriter -

Throws:

HiveException

setLongValue

public void setLongValue(VectorHashKeyWrapper kw,
                         int keyIndex,
                         Long value)
                  throws HiveException

Throws:

HiveException

assignRowColumn

public void assignRowColumn(org.apache.hadoop.hive.ql.exec.vector.VectorizedRowBatch batch,
                            int batchIndex,
                            int keyIndex,
                            VectorHashKeyWrapper kw)
                     throws HiveException

Throws:

HiveException

getVariableSize

public int getVariableSize(int batchSize)