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, TezBucketJoinProcCtx

public class BucketJoinProcCtx
extends Object
implements NodeProcessorCtx

Constructor Summary

BucketJoinProcCtx(HiveConf conf)

Method Summary

String	getBaseBigAlias()
Map<Partition,List<String>>	getBigTblPartsToBucketFileNames()
Map<Partition,Integer>	getBigTblPartsToBucketNumber()
HiveConf	getConf()
Set<JoinOperator>	getConvertedJoinOps()
List<String>	getJoinAliases()
Set<JoinOperator>	getRejectedJoinOps()
Map<String,List<List<String>>>	getTblAliasToBucketedFilePathsInEachPartition()
Map<String,List<Integer>>	getTblAliasToNumberOfBucketsInEachPartition()
boolean	isBigTablePartitioned()
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)
void	setTblAliasToBucketedFilePathsInEachPartition(Map<String,List<List<String>>> tblAliasToBucketedFilePathsInEachPartition)
void	setTblAliasToNumberOfBucketsInEachPartition(Map<String,List<Integer>> tblAliasToNumberOfBucketsInEachPartition)

Methods inherited from class java.lang.Object

equals, 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)

getTblAliasToNumberOfBucketsInEachPartition

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

getTblAliasToBucketedFilePathsInEachPartition

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

getBigTblPartsToBucketFileNames

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

getBigTblPartsToBucketNumber

public Map<Partition,Integer> getBigTblPartsToBucketNumber()

setTblAliasToNumberOfBucketsInEachPartition

public void setTblAliasToNumberOfBucketsInEachPartition(Map<String,List<Integer>> tblAliasToNumberOfBucketsInEachPartition)

setTblAliasToBucketedFilePathsInEachPartition

public void setTblAliasToBucketedFilePathsInEachPartition(Map<String,List<List<String>>> tblAliasToBucketedFilePathsInEachPartition)

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)