org.apache.hadoop.hive.ql.plan
Class BucketMapJoinContext

java.lang.Object
  org.apache.hadoop.hive.ql.plan.BucketMapJoinContext

All Implemented Interfaces:

Serializable

public class BucketMapJoinContext
extends Object
implements Serializable

was inner class of MapreLocalWork. context for bucket mapjoin (or smb join)

See Also:

Serialized Form

Constructor Summary

BucketMapJoinContext()

BucketMapJoinContext(MapJoinDesc clone)

Method Summary

String	createFileId(String inputPath)
String	createFileName(String inputPath, String fileName)
void	deriveBucketMapJoinMapping()
Map<String,Map<String,List<String>>>	getAliasBucketBaseFileNameMapping()
Map<String,Map<String,List<String>>>	getAliasBucketFileNameMapping()
Map<String,List<String>>	getBigTablePartSpecToFileMapping()
Map<String,Integer>	getBucketFileNameMapping()
Class<? extends BucketMatcher>	getBucketMatcherClass()
String	getMapJoinBigTableAlias()
void	setAliasBucketBaseFileNameMapping(Map<String,Map<String,List<String>>> aliasBucketBaseFileNameMapping)
void	setAliasBucketFileNameMapping(Map<String,Map<String,List<String>>> aliasBucketFileNameMapping)
void	setBigTablePartSpecToFileMapping(Map<String,List<String>> bigTablePartSpecToFileMapping)
void	setBucketFileNameMapping(Map<String,Integer> bucketFileNameMapping)
void	setBucketMatcherClass(Class<? extends BucketMatcher> bucketMatcherClass)
void	setMapJoinBigTableAlias(String bigTableAlias)
String	toString()

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

BucketMapJoinContext

public BucketMapJoinContext()

BucketMapJoinContext

public BucketMapJoinContext(MapJoinDesc clone)

Method Detail

setMapJoinBigTableAlias

public void setMapJoinBigTableAlias(String bigTableAlias)

deriveBucketMapJoinMapping

public void deriveBucketMapJoinMapping()

getMapJoinBigTableAlias

public String getMapJoinBigTableAlias()

getBucketMatcherClass

public Class<? extends BucketMatcher> getBucketMatcherClass()

setBucketMatcherClass

public void setBucketMatcherClass(Class<? extends BucketMatcher> bucketMatcherClass)

getAliasBucketFileNameMapping

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

setAliasBucketFileNameMapping

public void setAliasBucketFileNameMapping(Map<String,Map<String,List<String>>> aliasBucketFileNameMapping)

toString

public String toString()

Overrides:

toString in class Object

getAliasBucketBaseFileNameMapping

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

setAliasBucketBaseFileNameMapping

public void setAliasBucketBaseFileNameMapping(Map<String,Map<String,List<String>>> aliasBucketBaseFileNameMapping)

getBucketFileNameMapping

public Map<String,Integer> getBucketFileNameMapping()

setBucketFileNameMapping

public void setBucketFileNameMapping(Map<String,Integer> bucketFileNameMapping)

getBigTablePartSpecToFileMapping

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

setBigTablePartSpecToFileMapping

public void setBigTablePartSpecToFileMapping(Map<String,List<String>> bigTablePartSpecToFileMapping)

createFileId

public String createFileId(String inputPath)

createFileName

public String createFileName(String inputPath,
                             String fileName)