public class SparkMapJoinProcessor extends MapJoinProcessor
MapJoinProcessor.CurrentMapJoin, MapJoinProcessor.Default, MapJoinProcessor.MapJoinDefault, MapJoinProcessor.MapJoinFS, MapJoinProcessor.MapJoinWalkerCtx
Constructor and Description |
---|
SparkMapJoinProcessor() |
Modifier and Type | Method and Description |
---|---|
MapJoinOperator |
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.
|
checkMapJoin, convertJoinOpMapJoinOp, convertSMBJoinToMapJoin, generateMapJoinOperator, genLocalWorkForMapJoin, genMapJoinOpAndLocalWork, genSelectPlan, getBigTableCandidates, getCurrentMapJoin, getDefault, getKeys, getMapJoinDefault, getMapJoinDesc, getMapJoinFS, transform
public MapJoinOperator convertMapJoin(HiveConf conf, JoinOperator op, boolean leftSrc, String[] baseSrc, List<String> mapAliases, int bigTablePos, boolean noCheckOuterJoin, boolean validateMapJoinTree) throws SemanticException
convertMapJoin
in class MapJoinProcessor
conf
- opParseCtxMap
- op
- join operatorjoinTree
- qb join treebigTablePos
- position of the source to be read as part of
map-reduce framework. All other sources are cached in memorynoCheckOuterJoin
- validateMapJoinTree
- SemanticException
Copyright © 2017 The Apache Software Foundation. All rights reserved.