Package | Description |
---|---|
org.apache.hadoop.hive.ql.exec |
Hive QL execution tasks, operators, functions and other handlers.
|
org.apache.hadoop.hive.ql.exec.vector.mapjoin.fast | |
org.apache.hadoop.hive.ql.exec.vector.mapjoin.optimized | |
org.apache.hadoop.hive.ql.optimizer | |
org.apache.hadoop.hive.ql.parse | |
org.apache.hadoop.hive.ql.plan |
Modifier and Type | Class and Description |
---|---|
class |
AbstractMapJoinOperator<T extends MapJoinDesc> |
Modifier and Type | Method and Description |
---|---|
void |
SMBMapJoinOperator.initializeMapredLocalWork(MapJoinDesc mjConf,
org.apache.hadoop.conf.Configuration hconf,
MapredLocalWork localWork,
org.apache.commons.logging.Log l4j) |
Constructor and Description |
---|
TemporaryHashSinkOperator(MapJoinDesc desc) |
Constructor and Description |
---|
AbstractMapJoinOperator(AbstractMapJoinOperator<? extends MapJoinDesc> mjop) |
MapJoinOperator(AbstractMapJoinOperator<? extends MapJoinDesc> mjop) |
SMBMapJoinOperator(AbstractMapJoinOperator<? extends MapJoinDesc> mapJoinOp) |
Modifier and Type | Field and Description |
---|---|
protected MapJoinDesc |
VectorMapJoinFastHashTableLoader.desc |
Constructor and Description |
---|
VectorMapJoinFastTableContainer(MapJoinDesc desc,
org.apache.hadoop.conf.Configuration hconf,
long keyCount) |
Modifier and Type | Method and Description |
---|---|
static VectorMapJoinOptimizedHashTable |
VectorMapJoinOptimizedCreateHashTable.createHashTable(MapJoinDesc desc,
MapJoinTableContainer mapJoinTableContainer) |
Modifier and Type | Method and Description |
---|---|
static MapJoinDesc |
MapJoinProcessor.getMapJoinDesc(HiveConf hconf,
JoinOperator op,
boolean leftInputJoin,
String[] baseSrc,
List<String> mapAliases,
int mapJoinPos,
boolean noCheckOuterJoin) |
Modifier and Type | Method and Description |
---|---|
AbstractMapJoinOperator<? extends MapJoinDesc> |
MapJoinProcessor.MapJoinWalkerCtx.getCurrMapJoinOp() |
List<AbstractMapJoinOperator<? extends MapJoinDesc>> |
MapJoinProcessor.MapJoinWalkerCtx.getListMapJoinsNoRed() |
List<AbstractMapJoinOperator<? extends MapJoinDesc>> |
MapJoinProcessor.MapJoinWalkerCtx.getListRejectedMapJoins() |
Modifier and Type | Method and Description |
---|---|
static int |
MapJoinFactory.getPositionParent(AbstractMapJoinOperator<? extends MapJoinDesc> op,
Stack<Node> stack) |
void |
MapJoinProcessor.MapJoinWalkerCtx.setCurrMapJoinOp(AbstractMapJoinOperator<? extends MapJoinDesc> currMapJoinOp) |
void |
MapJoinProcessor.MapJoinWalkerCtx.setListMapJoins(List<AbstractMapJoinOperator<? extends MapJoinDesc>> listMapJoinsNoRed) |
void |
MapJoinProcessor.MapJoinWalkerCtx.setListRejectedMapJoins(List<AbstractMapJoinOperator<? extends MapJoinDesc>> listRejectedMapJoins) |
Constructor and Description |
---|
MapJoinProcessor.MapJoinWalkerCtx(List<AbstractMapJoinOperator<? extends MapJoinDesc>> listMapJoinsNoRed,
ParseContext pGraphContext) |
Modifier and Type | Method and Description |
---|---|
List<AbstractMapJoinOperator<? extends MapJoinDesc>> |
ParseContext.getListMapJoinOpsNoReducer() |
Modifier and Type | Method and Description |
---|---|
void |
ParseContext.setListMapJoinOpsNoReducer(List<AbstractMapJoinOperator<? extends MapJoinDesc>> listMapJoinOpsNoReducer) |
Modifier and Type | Class and Description |
---|---|
class |
CommonMergeJoinDesc |
class |
SMBJoinDesc |
Constructor and Description |
---|
BucketMapJoinContext(MapJoinDesc clone) |
CommonMergeJoinDesc(int numBuckets,
int mapJoinConversionPos,
MapJoinDesc joinDesc) |
HashTableSinkDesc(MapJoinDesc clone) |
MapJoinDesc(MapJoinDesc clone) |
SMBJoinDesc(MapJoinDesc conf) |
SparkBucketMapJoinContext(MapJoinDesc clone) |
SparkHashTableSinkDesc(MapJoinDesc clone) |
Copyright © 2017 The Apache Software Foundation. All rights reserved.