org.apache.hadoop.hive.ql.plan

Class BucketMapJoinContext

java.lang.Object

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

All Implemented Interfaces:

Serializable

Direct Known Subclasses:

SparkBucketMapJoinContext

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

Constructors

Constructor and Description
BucketMapJoinContext()
BucketMapJoinContext(MapJoinDesc clone)

Method Summary

Methods

Modifier and Type	Method and Description
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()
String	getMappingBigFile(String alias, String smallFile) Given a small table input file, find the mapping big table input file with the smallest bucket number.
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

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

getMappingBigFile

public String getMappingBigFile(String alias,
                       String smallFile)

Given a small table input file, find the mapping big table input file with the smallest bucket number.

createFileId

public String createFileId(String inputPath)

createFileName

public String createFileName(String inputPath,
                    String fileName)