Package | Description |
---|---|
org.apache.hadoop.hive.ql.exec.persistence | |
org.apache.hadoop.hive.ql.exec.vector |
Modifier and Type | Method and Description |
---|---|
void |
MapJoinKeyObject.readFromVector(VectorHashKeyWrapper kw,
VectorExpressionWriter[] keyOutputWriters,
VectorHashKeyWrapperBatch keyWrapperBatch) |
static ByteStream.Output |
MapJoinKey.serializeVector(ByteStream.Output byteStream,
VectorHashKeyWrapper kw,
VectorExpressionWriter[] keyOutputWriters,
VectorHashKeyWrapperBatch keyWrapperBatch,
boolean[] nulls,
boolean[] sortableSortOrders,
byte[] nullMarkers,
byte[] notNullMarkers)
Serializes row to output for vectorized path.
|
JoinUtil.JoinResult |
MapJoinTableContainer.ReusableGetAdaptor.setFromVector(VectorHashKeyWrapper kw,
VectorExpressionWriter[] keyOutputWriters,
VectorHashKeyWrapperBatch keyWrapperBatch)
Changes current rows to which adaptor is referring to the rows corresponding to
the key represented by a VHKW object, and writers and batch used to interpret it.
|
Modifier and Type | Class and Description |
---|---|
static class |
VectorHashKeyWrapper.EmptyVectorHashKeyWrapper |
Modifier and Type | Field and Description |
---|---|
static VectorHashKeyWrapper |
VectorHashKeyWrapper.EMPTY_KEY_WRAPPER |
Modifier and Type | Method and Description |
---|---|
static VectorHashKeyWrapper |
VectorHashKeyWrapper.allocate(VectorHashKeyWrapper.HashContext ctx,
int longValuesCount,
int doubleValuesCount,
int byteValuesCount,
int decimalValuesCount,
int timestampValuesCount,
int intervalDayTimeValuesCount,
int keyCount) |
VectorHashKeyWrapper |
VectorHashKeyWrapperBatch.allocateKeyWrapper() |
VectorHashKeyWrapper[] |
VectorHashKeyWrapperBatch.getVectorHashKeyWrappers()
Accessor for the batch-sized array of key wrappers.
|
Modifier and Type | Method and Description |
---|---|
void |
VectorHashKeyWrapperBatch.assignRowColumn(org.apache.hadoop.hive.ql.exec.vector.VectorizedRowBatch batch,
int batchIndex,
int keyIndex,
VectorHashKeyWrapper kw) |
void |
VectorHashKeyWrapper.duplicateTo(VectorHashKeyWrapper clone) |
Object |
VectorHashKeyWrapperBatch.getWritableKeyValue(VectorHashKeyWrapper kw,
int keyIndex,
VectorExpressionWriter keyOutputWriter)
Get the row-mode writable object value of a key from a key wrapper
|
void |
VectorHashKeyWrapperBatch.setLongValue(VectorHashKeyWrapper kw,
int keyIndex,
Long value) |
Copyright © 2022 The Apache Software Foundation. All rights reserved.