org.apache.hadoop.hive.ql.optimizer

Class SparkMapJoinProcessor

java.lang.Object

org.apache.hadoop.hive.ql.optimizer.Transform

org.apache.hadoop.hive.ql.optimizer.MapJoinProcessor

org.apache.hadoop.hive.ql.optimizer.SparkMapJoinProcessor

public class SparkMapJoinProcessor
extends MapJoinProcessor

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.hadoop.hive.ql.optimizer.MapJoinProcessor

MapJoinProcessor.CurrentMapJoin, MapJoinProcessor.Default, MapJoinProcessor.MapJoinDefault, MapJoinProcessor.MapJoinFS, MapJoinProcessor.MapJoinWalkerCtx

Constructor Summary

Constructors

Constructor and Description
SparkMapJoinProcessor()

Method Summary

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.

Methods inherited from class org.apache.hadoop.hive.ql.optimizer.MapJoinProcessor

checkMapJoin, convertJoinOpMapJoinOp, convertJoinOpMapJoinOp, convertSMBJoinToMapJoin, generateMapJoinOperator, genLocalWorkForMapJoin, genMapJoinOpAndLocalWork, genSelectPlan, getBigTableCandidates, getCurrentMapJoin, getDefault, getKeys, getMapJoinDefault, getMapJoinDesc, getMapJoinDesc, getMapJoinFS, transform

Methods inherited from class org.apache.hadoop.hive.ql.optimizer.Transform

beginPerfLogging, endPerfLogging, endPerfLogging

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

SparkMapJoinProcessor

public SparkMapJoinProcessor()

Method Detail

convertMapJoin

public MapJoinOperator convertMapJoin(HiveConf conf,
                                      JoinOperator op,
                                      boolean leftSrc,
                                      String[] baseSrc,
                                      List<String> mapAliases,
                                      int bigTablePos,
                                      boolean noCheckOuterJoin,
                                      boolean validateMapJoinTree)
                               throws SemanticException

convert a regular join to a a map-side join.

Overrides:

convertMapJoin in class MapJoinProcessor

Parameters:

conf -

opParseCtxMap -

op - join operator

joinTree - qb join tree

bigTablePos - position of the source to be read as part of map-reduce framework. All other sources are cached in memory

noCheckOuterJoin -

validateMapJoinTree -

Throws:

SemanticException