Package | Description |
---|---|
org.apache.hadoop.hive.ql.exec |
Hive QL execution tasks, operators, functions and other handlers.
|
org.apache.hadoop.hive.ql.exec.persistence | |
org.apache.hadoop.hive.ql.exec.vector | |
org.apache.hadoop.hive.ql.exec.vector.mapjoin | |
org.apache.hadoop.hive.ql.exec.vector.mapjoin.fast | |
org.apache.hadoop.hive.ql.exec.vector.mapjoin.hashtable | |
org.apache.hadoop.hive.ql.exec.vector.mapjoin.optimized |
Modifier and Type | Method and Description |
---|---|
protected JoinUtil.JoinResult |
MapJoinOperator.setMapJoinKey(MapJoinTableContainer.ReusableGetAdaptor dest,
Object row,
byte alias) |
static JoinUtil.JoinResult |
JoinUtil.JoinResult.valueOf(String name)
Returns the enum constant of this type with the specified name.
|
static JoinUtil.JoinResult[] |
JoinUtil.JoinResult.values()
Returns an array containing the constants of this enum type, in
the order they are declared.
|
Modifier and Type | Method and Description |
---|---|
JoinUtil.JoinResult |
ReusableGetAdaptorDirectAccess.setDirect(byte[] bytes,
int offset,
int length,
BytesBytesMultiHashMap.Result hashMapResult) |
JoinUtil.JoinResult |
MapJoinTableContainer.ReusableGetAdaptor.setFromOther(MapJoinTableContainer.ReusableGetAdaptor other)
Changes current rows to which adaptor is referring to the rows corresponding to
the key that another adaptor has already deserialized via setFromVector/setFromRow.
|
JoinUtil.JoinResult |
MapJoinTableContainer.ReusableGetAdaptor.setFromRow(Object row,
List<ExprNodeEvaluator> fields,
List<ObjectInspector> ois)
Changes current rows to which adaptor is referring to the rows corresponding to
the key represented by a row object, and fields and ois used to interpret it.
|
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 | Method and Description |
---|---|
protected JoinUtil.JoinResult |
VectorMapJoinOperator.setMapJoinKey(MapJoinTableContainer.ReusableGetAdaptor dest,
Object row,
byte alias) |
Modifier and Type | Method and Description |
---|---|
protected void |
VectorMapJoinInnerBigOnlyGenerateResultOperator.finishInnerBigOnlyRepeated(org.apache.hadoop.hive.ql.exec.vector.VectorizedRowBatch batch,
JoinUtil.JoinResult joinResult,
VectorMapJoinHashMultiSetResult hashMultiSetResult) |
protected void |
VectorMapJoinInnerGenerateResultOperator.finishInnerRepeated(org.apache.hadoop.hive.ql.exec.vector.VectorizedRowBatch batch,
JoinUtil.JoinResult joinResult,
VectorMapJoinHashTableResult hashMapResult) |
protected void |
VectorMapJoinLeftSemiGenerateResultOperator.finishLeftSemiRepeated(org.apache.hadoop.hive.ql.exec.vector.VectorizedRowBatch batch,
JoinUtil.JoinResult joinResult,
VectorMapJoinHashTableResult hashSetResult) |
void |
VectorMapJoinOuterGenerateResultOperator.finishOuterRepeated(org.apache.hadoop.hive.ql.exec.vector.VectorizedRowBatch batch,
JoinUtil.JoinResult joinResult,
VectorMapJoinHashMapResult hashMapResult,
boolean someRowsFilteredOut,
boolean inputSelectedInUse,
int inputLogicalSize)
Generate the outer join output results for one vectorized row batch with a repeated key.
|
Modifier and Type | Method and Description |
---|---|
JoinUtil.JoinResult |
VectorMapJoinFastBytesHashMultiSet.contains(byte[] keyBytes,
int keyStart,
int keyLength,
VectorMapJoinHashMultiSetResult hashMultiSetResult) |
JoinUtil.JoinResult |
VectorMapJoinFastBytesHashSet.contains(byte[] keyBytes,
int keyStart,
int keyLength,
VectorMapJoinHashSetResult hashSetResult) |
JoinUtil.JoinResult |
VectorMapJoinFastLongHashMultiSet.contains(long key,
VectorMapJoinHashMultiSetResult hashMultiSetResult) |
JoinUtil.JoinResult |
VectorMapJoinFastLongHashSet.contains(long key,
VectorMapJoinHashSetResult hashSetResult) |
JoinUtil.JoinResult |
VectorMapJoinFastBytesHashMap.lookup(byte[] keyBytes,
int keyStart,
int keyLength,
VectorMapJoinHashMapResult hashMapResult) |
JoinUtil.JoinResult |
VectorMapJoinFastLongHashMap.lookup(long key,
VectorMapJoinHashMapResult hashMapResult) |
Modifier and Type | Method and Description |
---|---|
JoinUtil.JoinResult |
VectorMapJoinBytesHashMultiSet.contains(byte[] keyBytes,
int keyStart,
int keyLength,
VectorMapJoinHashMultiSetResult hashMultiSetResult) |
JoinUtil.JoinResult |
VectorMapJoinBytesHashSet.contains(byte[] keyBytes,
int keyStart,
int keyLength,
VectorMapJoinHashSetResult hashSetResult) |
JoinUtil.JoinResult |
VectorMapJoinLongHashMultiSet.contains(long key,
VectorMapJoinHashMultiSetResult hashMultiSetResult) |
JoinUtil.JoinResult |
VectorMapJoinLongHashSet.contains(long key,
VectorMapJoinHashSetResult hashSetResult) |
JoinUtil.JoinResult |
VectorMapJoinHashTableResult.joinResult() |
JoinUtil.JoinResult |
VectorMapJoinBytesHashMap.lookup(byte[] keyBytes,
int keyStart,
int keyLength,
VectorMapJoinHashMapResult hashMapResult) |
JoinUtil.JoinResult |
VectorMapJoinLongHashMap.lookup(long key,
VectorMapJoinHashMapResult hashMapResult) |
Modifier and Type | Method and Description |
---|---|
void |
VectorMapJoinHashTableResult.setJoinResult(JoinUtil.JoinResult joinResult)
Set the current join result.
|
Modifier and Type | Method and Description |
---|---|
JoinUtil.JoinResult |
VectorMapJoinOptimizedHashMultiSet.contains(byte[] keyBytes,
int keyOffset,
int keyLength,
VectorMapJoinHashMultiSetResult hashMultiSetResult) |
JoinUtil.JoinResult |
VectorMapJoinOptimizedStringHashMultiSet.contains(byte[] keyBytes,
int keyStart,
int keyLength,
VectorMapJoinHashMultiSetResult hashMultiSetResult) |
JoinUtil.JoinResult |
VectorMapJoinOptimizedStringHashSet.contains(byte[] keyBytes,
int keyStart,
int keyLength,
VectorMapJoinHashSetResult hashSetResult) |
JoinUtil.JoinResult |
VectorMapJoinOptimizedHashSet.contains(byte[] keyBytes,
int keyOffset,
int keyLength,
VectorMapJoinHashSetResult hashSetResult) |
JoinUtil.JoinResult |
VectorMapJoinOptimizedLongHashMultiSet.contains(long key,
VectorMapJoinHashMultiSetResult hashMultiSetResult) |
JoinUtil.JoinResult |
VectorMapJoinOptimizedLongHashSet.contains(long key,
VectorMapJoinHashSetResult hashSetResult) |
JoinUtil.JoinResult |
VectorMapJoinOptimizedHashTable.doLookup(byte[] keyBytes,
int keyOffset,
int keyLength,
BytesBytesMultiHashMap.Result bytesBytesMultiHashMapResult,
VectorMapJoinHashTableResult hashTableResult) |
JoinUtil.JoinResult |
VectorMapJoinOptimizedHashMap.lookup(byte[] keyBytes,
int keyOffset,
int keyLength,
VectorMapJoinHashMapResult hashMapResult) |
JoinUtil.JoinResult |
VectorMapJoinOptimizedStringHashMap.lookup(byte[] keyBytes,
int keyStart,
int keyLength,
VectorMapJoinHashMapResult hashMapResult) |
JoinUtil.JoinResult |
VectorMapJoinOptimizedLongHashMap.lookup(long key,
VectorMapJoinHashMapResult hashMapResult) |
Copyright © 2022 The Apache Software Foundation. All rights reserved.