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

Constructors

Constructor and Description
BucketJoinProcCtx(HiveConf conf)

Method Summary

Methods

Modifier and Type	Method and Description
Map<String,String>	getAliasToNewAliasMap()
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	setAliasToNewAliasMap(Map<String,String> aliasToNewAliasMap)
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

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)

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)

setAliasToNewAliasMap

public void setAliasToNewAliasMap(Map<String,String> aliasToNewAliasMap)

getAliasToNewAliasMap

public Map<String,String> getAliasToNewAliasMap()