Modifier and Type | Method and Description |
---|---|
Set<JoinOperator> |
BucketJoinProcCtx.getConvertedJoinOps() |
Set<JoinOperator> |
SkewJoinOptimizer.SkewJoinOptProcCtx.getDoneJoins() |
Set<JoinOperator> |
BucketJoinProcCtx.getRejectedJoinOps() |
Modifier and Type | Method and Description |
---|---|
protected boolean |
AbstractSMBJoinProc.canConvertJoinToBucketMapJoin(JoinOperator joinOp,
SortBucketJoinProcCtx context) |
protected boolean |
AbstractSMBJoinProc.canConvertJoinToSMBJoin(JoinOperator joinOperator,
SortBucketJoinProcCtx smbJoinContext) |
protected boolean |
AbstractSMBJoinProc.checkConvertJoinToSMBJoin(JoinOperator joinOperator,
SortBucketJoinProcCtx smbJoinContext) |
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) |
protected void |
AbstractSMBJoinProc.convertJoinToSMBJoin(JoinOperator joinOp,
SortBucketJoinProcCtx smbJoinContext) |
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.
|
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 |
MapJoinProcessor.generateMapJoinOperator(ParseContext pctx,
JoinOperator op,
int mapJoinPos) |
static void |
MapJoinProcessor.genMapJoinOpAndLocalWork(HiveConf conf,
MapredWork newWork,
JoinOperator op,
int mapJoinPos)
Convert the join to a map-join and also generate any local work needed.
|
int |
TableSizeBasedBigTableSelectorForAutoSMJ.getBigTablePosition(ParseContext parseCtx,
JoinOperator joinOp,
Set<Integer> bigTableCandidates) |
int |
LeftmostBigTableSelectorForAutoSMJ.getBigTablePosition(ParseContext parseContext,
JoinOperator joinOp,
Set<Integer> bigTableCandidates) |
int |
BigTableSelectorForAutoSMJ.getBigTablePosition(ParseContext parseContext,
JoinOperator joinOp,
Set<Integer> joinCandidates) |
int |
AvgPartitionSizeBasedBigTableSelectorForAutoSMJ.getBigTablePosition(ParseContext parseCtx,
JoinOperator joinOp,
Set<Integer> bigTableCandidates) |
static ObjectPair<List<ReduceSinkOperator>,Map<Byte,List<ExprNodeDesc>>> |
MapJoinProcessor.getKeys(boolean leftInputJoin,
String[] baseSrc,
JoinOperator op) |
int |
ConvertJoinMapJoin.getMapJoinConversionPos(JoinOperator joinOp,
OptimizeTezProcContext context,
int buckets,
boolean skipJoinTypeChecks,
long maxSize) |
static MapJoinDesc |
MapJoinProcessor.getMapJoinDesc(HiveConf hconf,
JoinOperator op,
boolean leftInputJoin,
String[] baseSrc,
List<String> mapAliases,
int mapJoinPos,
boolean noCheckOuterJoin) |
static MapJoinDesc |
MapJoinProcessor.getMapJoinDesc(HiveConf hconf,
JoinOperator op,
boolean leftInputJoin,
String[] baseSrc,
List<String> mapAliases,
int mapJoinPos,
boolean noCheckOuterJoin,
boolean adjustParentsChildren) |
Modifier and Type | Method and Description |
---|---|
void |
BucketJoinProcCtx.setConvertedJoinOps(Set<JoinOperator> setOfConvertedJoins) |
void |
SkewJoinOptimizer.SkewJoinOptProcCtx.setDoneJoins(Set<JoinOperator> doneJoins) |
void |
BucketJoinProcCtx.setRejectedJoinOps(Set<JoinOperator> rejectedJoinOps) |
Modifier and Type | Method and Description |
---|---|
protected static <T extends Operator<?>> |
CorrelationUtilities.findParents(JoinOperator join,
Class<T> target) |
protected static boolean[] |
CorrelationUtilities.getSortedTags(JoinOperator joinOp) |
protected static boolean |
CorrelationUtilities.isSortedTag(JoinOperator joinOp,
int tag) |
protected boolean |
ReduceSinkDeDuplication.AbsctractReducerReducerProc.merge(ReduceSinkOperator cRS,
JoinOperator pJoin,
int minReducer) |
Modifier and Type | Method and Description |
---|---|
static void |
GenMRSkewJoinProcessor.processSkewJoin(JoinOperator joinOp,
Task<? extends Serializable> currTask,
ParseContext parseCtx)
Create tasks for processing skew joins.
|
static void |
GenSparkSkewJoinProcessor.processSkewJoin(JoinOperator joinOp,
Task<? extends Serializable> currTask,
ReduceWork reduceWork,
ParseContext parseCtx) |
static boolean |
GenMRSkewJoinProcessor.skewJoinEnabled(HiveConf conf,
JoinOperator joinOp) |
Modifier and Type | Method and Description |
---|---|
static Set<JoinOperator> |
SparkSkewJoinProcFactory.getVisitedJoinOp() |
Modifier and Type | Method and Description |
---|---|
protected boolean |
SparkSortMergeJoinOptimizer.canConvertJoinToSMBJoin(JoinOperator joinOperator,
SortBucketJoinProcCtx smbJoinContext,
ParseContext pGraphContext,
Stack<Node> stack) |
MapJoinOperator |
SparkMapJoinOptimizer.convertJoinMapJoin(JoinOperator joinOp,
OptimizeSparkProcContext context,
int bigTablePosition) |
protected SMBMapJoinOperator |
SparkSortMergeJoinOptimizer.convertJoinToSMBJoinAndReturn(JoinOperator joinOp,
SortBucketJoinProcCtx smbJoinContext) |
Modifier and Type | Method and Description |
---|---|
Set<JoinOperator> |
ParseContext.getJoinOps() |
Modifier and Type | Method and Description |
---|---|
void |
ParseContext.setJoinOps(Set<JoinOperator> joinOps) |
Copyright © 2016 The Apache Software Foundation. All rights reserved.