Modifier and Type | Method and Description |
---|---|
void |
HashTableLoader.init(ExecMapperContext context,
MapredContext mrContext,
org.apache.hadoop.conf.Configuration hconf,
MapJoinOperator joinOp) |
Constructor and Description |
---|
HashTableSinkOperator(CompilationOpContext ctx,
MapJoinOperator mjop) |
Modifier and Type | Method and Description |
---|---|
void |
HashTableLoader.init(ExecMapperContext context,
MapredContext mrContext,
org.apache.hadoop.conf.Configuration hconf,
MapJoinOperator joinOp) |
Modifier and Type | Method and Description |
---|---|
void |
HashTableLoader.init(ExecMapperContext context,
MapredContext mrContext,
org.apache.hadoop.conf.Configuration hconf,
MapJoinOperator joinOp) |
Modifier and Type | Method and Description |
---|---|
void |
HashTableLoader.init(ExecMapperContext context,
MapredContext mrContext,
org.apache.hadoop.conf.Configuration hconf,
MapJoinOperator joinOp) |
Modifier and Type | Class and Description |
---|---|
class |
VectorMapJoinBaseOperator
The *NON-NATIVE* base vector map join operator class used by VectorMapJoinOperator and
VectorMapJoinOuterFilteredOperator.
|
class |
VectorMapJoinOperator
The vectorized version of the MapJoinOperator.
|
class |
VectorMapJoinOuterFilteredOperator
This is the *NON-NATIVE* vector map join operator for just LEFT OUTER JOIN and filtered.
|
Modifier and Type | Method and Description |
---|---|
void |
VectorMapJoinFastHashTableLoader.init(ExecMapperContext context,
MapredContext mrContext,
org.apache.hadoop.conf.Configuration hconf,
MapJoinOperator joinOp) |
Modifier and Type | Method and Description |
---|---|
MapJoinOperator |
ConvertJoinMapJoin.convertJoinMapJoin(JoinOperator joinOp,
OptimizeTezProcContext context,
int bigTablePosition,
boolean removeReduceSink) |
static MapJoinOperator |
MapJoinProcessor.convertJoinOpMapJoinOp(HiveConf hconf,
JoinOperator op,
boolean leftInputJoin,
String[] baseSrc,
List<String> mapAliases,
int mapJoinPos,
boolean noCheckOuterJoin) |
static MapJoinOperator |
MapJoinProcessor.convertJoinOpMapJoinOp(HiveConf hconf,
JoinOperator op,
boolean leftInputJoin,
String[] baseSrc,
List<String> mapAliases,
int mapJoinPos,
boolean noCheckOuterJoin,
boolean adjustParentsChildren) |
protected MapJoinOperator |
AbstractSMBJoinProc.convertJoinToBucketMapJoin(JoinOperator joinOp,
SortBucketJoinProcCtx joinContext) |
MapJoinOperator |
MapJoinProcessor.convertMapJoin(HiveConf conf,
JoinOperator op,
boolean leftInputJoin,
String[] baseSrc,
List<String> mapAliases,
int mapJoinPos,
boolean noCheckOuterJoin,
boolean validateMapJoinTree)
convert a regular join to a a map-side join.
|
MapJoinOperator |
SparkMapJoinProcessor.convertMapJoin(HiveConf conf,
JoinOperator op,
boolean leftSrc,
String[] baseSrc,
List<String> mapAliases,
int bigTablePos,
boolean noCheckOuterJoin,
boolean validateMapJoinTree)
convert a regular join to a a map-side join.
|
static MapJoinOperator |
MapJoinProcessor.convertSMBJoinToMapJoin(HiveConf hconf,
SMBMapJoinOperator smbJoinOp,
int bigTablePos,
boolean noCheckOuterJoin)
convert a sortmerge join to a a map-side join.
|
MapJoinOperator |
MapJoinProcessor.generateMapJoinOperator(ParseContext pctx,
JoinOperator op,
int mapJoinPos) |
Modifier and Type | Method and Description |
---|---|
protected boolean |
AbstractSMBJoinProc.canConvertBucketMapJoinToSMBJoin(MapJoinOperator mapJoinOp,
Stack<Node> stack,
SortBucketJoinProcCtx smbJoinContext,
Object... nodeOutputs) |
protected boolean |
AbstractBucketJoinProc.canConvertMapJoinToBucketMapJoin(MapJoinOperator mapJoinOp,
BucketJoinProcCtx context) |
static void |
BucketMapjoinProc.checkAndConvertBucketMapJoin(ParseContext pGraphContext,
MapJoinOperator mapJoinOp,
String baseBigAlias,
List<String> joinAliases)
Check if a mapjoin can be converted to a bucket mapjoin,
and do the version if possible.
|
protected SMBMapJoinOperator |
AbstractSMBJoinProc.convertBucketMapJoinToSMBJoin(MapJoinOperator mapJoinOp,
SortBucketJoinProcCtx smbJoinContext) |
protected void |
AbstractBucketJoinProc.convertMapJoinToBucketMapJoin(MapJoinOperator mapJoinOp,
BucketJoinProcCtx context) |
static void |
MapJoinProcessor.genLocalWorkForMapJoin(MapredWork newWork,
MapJoinOperator newMapJoinOp,
int mapJoinPos) |
protected void |
MapJoinProcessor.genSelectPlan(ParseContext pctx,
MapJoinOperator input) |
static Object |
ReduceSinkMapJoinProc.processReduceSinkToHashJoin(ReduceSinkOperator parentRS,
MapJoinOperator mapJoinOp,
GenTezProcContext context) |
Modifier and Type | Method and Description |
---|---|
Map<MapJoinOperator,List<Operator<? extends OperatorDesc>>> |
MapJoinResolver.LocalMapJoinProcCtx.getDirectWorks() |
Modifier and Type | Method and Description |
---|---|
void |
MapJoinResolver.LocalMapJoinProcCtx.addDirectWorks(MapJoinOperator mapJoinOp,
List<Operator<? extends OperatorDesc>> directOperators) |
Modifier and Type | Method and Description |
---|---|
void |
MapJoinResolver.LocalMapJoinProcCtx.setDirectWorks(Map<MapJoinOperator,List<Operator<? extends OperatorDesc>>> directWorks) |
Modifier and Type | Method and Description |
---|---|
MapJoinOperator |
SparkMapJoinOptimizer.convertJoinMapJoin(JoinOperator joinOp,
OptimizeSparkProcContext context,
int bigTablePosition) |
Modifier and Type | Field and Description |
---|---|
Set<MapJoinOperator> |
GenTezProcContext.currentMapJoinOperators |
Map<MapJoinOperator,List<Operator<?>>> |
GenTezProcContext.mapJoinParentMap |
Map<MapJoinOperator,Set<ReduceSinkOperator>> |
GenTezProcContext.mapJoinToUnprocessedSmallTableReduceSinks |
Map<MapJoinOperator,List<BaseWork>> |
GenTezProcContext.mapJoinWorkMap |
Map<Operator<?>,MapJoinOperator> |
GenTezProcContext.smallTableParentToMapJoinMap |
Modifier and Type | Method and Description |
---|---|
Set<MapJoinOperator> |
ParseContext.getMapJoinOps() |
Modifier and Type | Method and Description |
---|---|
void |
ParseContext.setMapJoinOps(Set<MapJoinOperator> mapJoinOps) |
Modifier and Type | Field and Description |
---|---|
Set<MapJoinOperator> |
GenSparkProcContext.currentMapJoinOperators |
Map<MapJoinOperator,List<Operator<?>>> |
GenSparkProcContext.mapJoinParentMap |
Map<MapJoinOperator,List<BaseWork>> |
GenSparkProcContext.mapJoinWorkMap |
Modifier and Type | Method and Description |
---|---|
Map<MapJoinOperator,Long> |
OptimizeSparkProcContext.getMjOpSizes() |
Modifier and Type | Method and Description |
---|---|
Map<MapJoinOperator,List<Operator<? extends OperatorDesc>>> |
MapredLocalWork.getDirectFetchOp() |
Modifier and Type | Method and Description |
---|---|
MapredLocalWork |
MapredLocalWork.extractDirectWorks(Map<MapJoinOperator,List<Operator<? extends OperatorDesc>>> directWorks) |
void |
MapredLocalWork.setDirectFetchOp(Map<MapJoinOperator,List<Operator<? extends OperatorDesc>>> op) |
Copyright © 2022 The Apache Software Foundation. All rights reserved.