Package | Description |
---|---|
org.apache.hadoop.hive.ql.exec |
Hive QL execution tasks, operators, functions and other handlers.
|
org.apache.hadoop.hive.ql.exec.mr | |
org.apache.hadoop.hive.ql.exec.persistence | |
org.apache.hadoop.hive.ql.exec.spark | |
org.apache.hadoop.hive.ql.exec.tez | |
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 | Field and Description |
---|---|
protected MapJoinTableContainer[] |
MapJoinOperator.mapJoinTables |
Modifier and Type | Method and Description |
---|---|
MapJoinTableContainer[] |
HashTableSinkOperator.getMapJoinTables() |
Modifier and Type | Method and Description |
---|---|
void |
HashTableLoader.load(MapJoinTableContainer[] mapJoinTables,
MapJoinTableContainerSerDe[] mapJoinTableSerdes) |
void |
MapJoinOperator.setTestMapJoinTableContainer(int posSmallTable,
MapJoinTableContainer testMapJoinTableContainer,
MapJoinTableContainerSerDe mapJoinTableContainerSerDe) |
protected void |
MapJoinOperator.spillBigTableRow(MapJoinTableContainer hybridHtContainer,
Object row)
Postpone processing the big table row temporarily by spilling it to a row container
|
Modifier and Type | Method and Description |
---|---|
void |
HashTableLoader.load(MapJoinTableContainer[] mapJoinTables,
MapJoinTableContainerSerDe[] mapJoinTableSerdes) |
Modifier and Type | Interface and Description |
---|---|
interface |
MapJoinPersistableTableContainer |
Modifier and Type | Class and Description |
---|---|
class |
AbstractMapJoinTableContainer |
class |
HashMapWrapper
Simple wrapper for persistent Hashmap implementing only the put/get/remove/clear interface.
|
class |
HybridHashTableContainer
Hash table container that can have many partitions -- each partition has its own hashmap,
as well as row container for small table and big table.
|
class |
MapJoinBytesTableContainer
Table container that serializes keys and values using LazyBinarySerDe into
BytesBytesMultiHashMap, with very low memory overhead.
|
Modifier and Type | Method and Description |
---|---|
MapJoinTableContainer |
MapJoinTableContainerSerDe.load(org.apache.hadoop.fs.FileSystem fs,
org.apache.hadoop.fs.Path folder,
org.apache.hadoop.conf.Configuration hconf)
Loads the table container from a folder.
|
MapJoinTableContainer |
MapJoinTableContainerSerDe.loadFastContainer(MapJoinDesc mapJoinDesc,
org.apache.hadoop.fs.FileSystem fs,
org.apache.hadoop.fs.Path folder,
org.apache.hadoop.conf.Configuration hconf)
Loads the small table into a VectorMapJoinFastTableContainer.
|
Modifier and Type | Method and Description |
---|---|
static MapJoinTableContainer |
SmallTableCache.get(org.apache.hadoop.fs.Path path) |
Modifier and Type | Method and Description |
---|---|
static void |
SmallTableCache.cache(org.apache.hadoop.fs.Path path,
MapJoinTableContainer tableContainer) |
void |
HashTableLoader.load(MapJoinTableContainer[] mapJoinTables,
MapJoinTableContainerSerDe[] mapJoinTableSerdes) |
Modifier and Type | Method and Description |
---|---|
void |
HashTableLoader.load(MapJoinTableContainer[] mapJoinTables,
MapJoinTableContainerSerDe[] mapJoinTableSerdes) |
Modifier and Type | Method and Description |
---|---|
protected void |
VectorMapJoinOperator.spillBigTableRow(MapJoinTableContainer hybridHtContainer,
Object row) |
Modifier and Type | Method and Description |
---|---|
void |
VectorMapJoinCommonOperator.setTestMapJoinTableContainer(int posSmallTable,
MapJoinTableContainer testMapJoinTableContainer,
MapJoinTableContainerSerDe mapJoinTableContainerSerDe) |
Modifier and Type | Class and Description |
---|---|
class |
VectorMapJoinFastTableContainer
HashTableLoader for Tez constructs the hashtable from records read from
a broadcast edge.
|
Modifier and Type | Method and Description |
---|---|
void |
VectorMapJoinFastHashTableLoader.load(MapJoinTableContainer[] mapJoinTables,
MapJoinTableContainerSerDe[] mapJoinTableSerdes) |
Modifier and Type | Interface and Description |
---|---|
interface |
VectorMapJoinTableContainer |
Modifier and Type | Field and Description |
---|---|
protected MapJoinTableContainer |
VectorMapJoinOptimizedHashTable.originalTableContainer |
Modifier and Type | Method and Description |
---|---|
static VectorMapJoinOptimizedHashTable |
VectorMapJoinOptimizedCreateHashTable.createHashTable(MapJoinDesc desc,
MapJoinTableContainer mapJoinTableContainer) |
Copyright © 2022 The Apache Software Foundation. All rights reserved.