public class BucketJoinProcCtx extends java.lang.Object implements NodeProcessorCtx
Constructor and Description |
---|
BucketJoinProcCtx(HiveConf conf) |
Modifier and Type | Method and Description |
---|---|
java.lang.String |
getBaseBigAlias() |
java.util.Map<Partition,java.util.List<java.lang.String>> |
getBigTblPartsToBucketFileNames() |
java.util.Map<Partition,java.lang.Integer> |
getBigTblPartsToBucketNumber() |
HiveConf |
getConf() |
java.util.Set<JoinOperator> |
getConvertedJoinOps() |
java.util.List<java.lang.String> |
getJoinAliases() |
java.util.Set<JoinOperator> |
getRejectedJoinOps() |
java.util.Map<java.lang.String,java.util.List<java.util.List<java.lang.String>>> |
getTblAliasToBucketedFilePathsInEachPartition() |
java.util.Map<java.lang.String,java.util.List<java.lang.Integer>> |
getTblAliasToNumberOfBucketsInEachPartition() |
boolean |
isBigTablePartitioned() |
void |
setBaseBigAlias(java.lang.String baseBigAlias) |
void |
setBigTablePartitioned(boolean bigTablePartitioned) |
void |
setBigTblPartsToBucketFileNames(java.util.Map<Partition,java.util.List<java.lang.String>> bigTblPartsToBucketFileNames) |
void |
setBigTblPartsToBucketNumber(java.util.Map<Partition,java.lang.Integer> bigTblPartsToBucketNumber) |
void |
setConvertedJoinOps(java.util.Set<JoinOperator> setOfConvertedJoins) |
void |
setJoinAliases(java.util.List<java.lang.String> joinAliases) |
void |
setRejectedJoinOps(java.util.Set<JoinOperator> rejectedJoinOps) |
void |
setTblAliasToBucketedFilePathsInEachPartition(java.util.Map<java.lang.String,java.util.List<java.util.List<java.lang.String>>> tblAliasToBucketedFilePathsInEachPartition) |
void |
setTblAliasToNumberOfBucketsInEachPartition(java.util.Map<java.lang.String,java.util.List<java.lang.Integer>> tblAliasToNumberOfBucketsInEachPartition) |
public BucketJoinProcCtx(HiveConf conf)
public HiveConf getConf()
public java.util.Set<JoinOperator> getRejectedJoinOps()
public java.util.Set<JoinOperator> getConvertedJoinOps()
public void setRejectedJoinOps(java.util.Set<JoinOperator> rejectedJoinOps)
public void setConvertedJoinOps(java.util.Set<JoinOperator> setOfConvertedJoins)
public java.util.Map<java.lang.String,java.util.List<java.lang.Integer>> getTblAliasToNumberOfBucketsInEachPartition()
public java.util.Map<java.lang.String,java.util.List<java.util.List<java.lang.String>>> getTblAliasToBucketedFilePathsInEachPartition()
public java.util.Map<Partition,java.util.List<java.lang.String>> getBigTblPartsToBucketFileNames()
public java.util.Map<Partition,java.lang.Integer> getBigTblPartsToBucketNumber()
public void setTblAliasToNumberOfBucketsInEachPartition(java.util.Map<java.lang.String,java.util.List<java.lang.Integer>> tblAliasToNumberOfBucketsInEachPartition)
public void setTblAliasToBucketedFilePathsInEachPartition(java.util.Map<java.lang.String,java.util.List<java.util.List<java.lang.String>>> tblAliasToBucketedFilePathsInEachPartition)
public void setBigTblPartsToBucketFileNames(java.util.Map<Partition,java.util.List<java.lang.String>> bigTblPartsToBucketFileNames)
public void setBigTblPartsToBucketNumber(java.util.Map<Partition,java.lang.Integer> bigTblPartsToBucketNumber)
public void setJoinAliases(java.util.List<java.lang.String> joinAliases)
public void setBaseBigAlias(java.lang.String baseBigAlias)
public java.util.List<java.lang.String> getJoinAliases()
public java.lang.String getBaseBigAlias()
public boolean isBigTablePartitioned()
public void setBigTablePartitioned(boolean bigTablePartitioned)
Copyright © 2012 The Apache Software Foundation