org.apache.hadoop.hive.ql.optimizer
Class BucketJoinProcCtx

java.lang.Object
  org.apache.hadoop.hive.ql.optimizer.BucketJoinProcCtx

All Implemented Interfaces:

NodeProcessorCtx

Direct Known Subclasses:

SortBucketJoinProcCtx

public class BucketJoinProcCtx
extends Object
implements NodeProcessorCtx

Constructor Summary

BucketJoinProcCtx(HiveConf conf)

Method Summary

Map<String,List<List<String>>>	getAliasToPartitionBucketFileNamesMapping()
Map<String,List<Integer>>	getAliasToPartitionBucketNumberMapping()
String	getBaseBigAlias()
Map<Partition,List<String>>	getBigTblPartsToBucketFileNames()
Map<Partition,Integer>	getBigTblPartsToBucketNumber()
HiveConf	getConf()
Set<JoinOperator>	getConvertedJoinOps()
List<String>	getJoinAliases()
Set<JoinOperator>	getRejectedJoinOps()
boolean	isBigTablePartitioned()
void	setAliasToPartitionBucketFileNamesMapping(Map<String,List<List<String>>> aliasToPartitionBucketFileNamesMapping)
void	setAliasToPartitionBucketNumberMapping(Map<String,List<Integer>> aliasToPartitionBucketNumberMapping)
void	setBaseBigAlias(String baseBigAlias)
void	setBigTablePartitioned(boolean bigTablePartitioned)
void	setBigTblPartsToBucketFileNames(Map<Partition,List<String>> bigTblPartsToBucketFileNames)
void	setBigTblPartsToBucketNumber(Map<Partition,Integer> bigTblPartsToBucketNumber)
void	setConvertedJoinOps(Set<JoinOperator> setOfConvertedJoins)
void	setJoinAliases(List<String> joinAliases)
void	setRejectedJoinOps(Set<JoinOperator> rejectedJoinOps)

Methods inherited from class java.lang.Object

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

Constructor Detail

BucketJoinProcCtx

public BucketJoinProcCtx(HiveConf conf)

Method Detail

getConf

public HiveConf getConf()

getRejectedJoinOps

public Set<JoinOperator> getRejectedJoinOps()

getConvertedJoinOps

public Set<JoinOperator> getConvertedJoinOps()

setRejectedJoinOps

public void setRejectedJoinOps(Set<JoinOperator> rejectedJoinOps)

setConvertedJoinOps

public void setConvertedJoinOps(Set<JoinOperator> setOfConvertedJoins)

getAliasToPartitionBucketNumberMapping

public Map<String,List<Integer>> getAliasToPartitionBucketNumberMapping()

getAliasToPartitionBucketFileNamesMapping

public Map<String,List<List<String>>> getAliasToPartitionBucketFileNamesMapping()

getBigTblPartsToBucketFileNames

public Map<Partition,List<String>> getBigTblPartsToBucketFileNames()

getBigTblPartsToBucketNumber

public Map<Partition,Integer> getBigTblPartsToBucketNumber()

setAliasToPartitionBucketNumberMapping

public void setAliasToPartitionBucketNumberMapping(Map<String,List<Integer>> aliasToPartitionBucketNumberMapping)

setAliasToPartitionBucketFileNamesMapping

public void setAliasToPartitionBucketFileNamesMapping(Map<String,List<List<String>>> aliasToPartitionBucketFileNamesMapping)

setBigTblPartsToBucketFileNames

public void setBigTblPartsToBucketFileNames(Map<Partition,List<String>> bigTblPartsToBucketFileNames)

setBigTblPartsToBucketNumber

public void setBigTblPartsToBucketNumber(Map<Partition,Integer> bigTblPartsToBucketNumber)

setJoinAliases

public void setJoinAliases(List<String> joinAliases)

setBaseBigAlias

public void setBaseBigAlias(String baseBigAlias)

getJoinAliases

public List<String> getJoinAliases()

getBaseBigAlias

public String getBaseBigAlias()

isBigTablePartitioned

public boolean isBigTablePartitioned()

setBigTablePartitioned

public void setBigTablePartitioned(boolean bigTablePartitioned)