org.apache.hadoop.hive.ql.plan

Class MapJoinDesc

java.lang.Object

org.apache.hadoop.hive.ql.plan.AbstractOperatorDesc

org.apache.hadoop.hive.ql.plan.JoinDesc

org.apache.hadoop.hive.ql.plan.MapJoinDesc

All Implemented Interfaces:

Serializable, Cloneable, OperatorDesc

Direct Known Subclasses:

CommonMergeJoinDesc, SMBJoinDesc

public class MapJoinDesc
extends JoinDesc
implements Serializable

Map Join operator Descriptor implementation.

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
protected boolean	genJoinKeys

Fields inherited from class org.apache.hadoop.hive.ql.plan.JoinDesc

conds, FULL_OUTER_JOIN, INNER_JOIN, LEFT_OUTER_JOIN, LEFT_SEMI_JOIN, noOuterJoin, outputColumnNames, RIGHT_OUTER_JOIN, tagOrder, UNIQUE_JOIN

Fields inherited from class org.apache.hadoop.hive.ql.plan.AbstractOperatorDesc

opProps, opTraits, statistics, vectorMode

Constructor Summary

Constructors

Constructor and Description
MapJoinDesc()
MapJoinDesc(Map<Byte,List<ExprNodeDesc>> keys, TableDesc keyTblDesc, Map<Byte,List<ExprNodeDesc>> values, List<TableDesc> valueTblDescs, List<TableDesc> valueFilteredTblDescs, List<String> outputColumnNames, int posBigTable, JoinCondDesc[] conds, Map<Byte,List<ExprNodeDesc>> filters, boolean noOuterJoin, String dumpFilePrefix)
MapJoinDesc(MapJoinDesc clone)

Method Summary

Methods

Modifier and Type	Method and Description
Map<String,Map<String,List<String>>>	getAliasBucketFileNameMapping()
String	getBigTableAlias()
Map<String,Integer>	getBigTableBucketNumMapping()
Map<String,List<String>>	getBigTablePartSpecToFileMapping()
String	getDumpFilePrefix()
boolean	getGenJoinKeys()
float	getHashTableMemoryUsage()
String	getKeyCountsExplainDesc()
Map<Byte,List<ExprNodeDesc>>	getKeys()
Map<Byte,String>	getKeysString()
TableDesc	getKeyTblDesc()
Map<Integer,Long>	getParentDataSizes()
Map<Integer,Long>	getParentKeyCounts()
Map<Integer,String>	getParentToInput()
int	getPosBigTable()
Map<Byte,List<Integer>>	getRetainList()
List<TableDesc>	getValueFilteredTblDescs()
int[]	getValueIndex(byte alias)
Map<Byte,int[]>	getValueIndices()
List<TableDesc>	getValueTblDescs()
VectorMapJoinDesc	getVectorDesc()
boolean	isBucketMapJoin()
boolean	isHybridHashJoin()
boolean	isMapSideJoin()
void	setAliasBucketFileNameMapping(Map<String,Map<String,List<String>>> aliasBucketFileNameMapping)
void	setBigTableAlias(String bigTableAlias)
void	setBigTableBucketNumMapping(Map<String,Integer> bigTableBucketNumMapping)
void	setBigTablePartSpecToFileMapping(Map<String,List<String>> partToFileMapping)
void	setBucketMapJoin(boolean isBucketMapJoin)
void	setDumpFilePrefix(String dumpFilePrefix)
void	setGenJoinKeys(boolean genJoinKeys)
void	setHashTableMemoryUsage(float hashtableMemoryUsage)
void	setHybridHashJoin(boolean isHybridHashJoin)
void	setKeys(Map<Byte,List<ExprNodeDesc>> keys)
void	setKeyTblDesc(TableDesc keyTblDesc)
void	setParentKeyCount(Map<Integer,Long> parentKeyCounts)
void	setParentToInput(Map<Integer,String> parentToInput)
void	setPosBigTable(int posBigTable)
void	setRetainList(Map<Byte,List<Integer>> retainList)
void	setValueFilteredTblDescs(List<TableDesc> valueFilteredTblDescs)
void	setValueIndices(Map<Byte,int[]> valueIndices)
void	setValueTblDescs(List<TableDesc> valueTblDescs)
void	setVectorDesc(VectorMapJoinDesc vectorDesc)

Methods inherited from class org.apache.hadoop.hive.ql.plan.JoinDesc

clone, cloneQBJoinTreeProps, convertToArray, getAliasToOpInfo, getBaseSrc, getBigKeysDirMap, getConds, getCondsList, getExprs, getFilterMap, getFilterMapString, getFilters, getFiltersStringMap, getHandleSkewJoin, getId, getKeyTableDesc, getLeftAlias, getLeftAliases, getMapAliases, getNoOuterJoin, getNullSafes, getNullSafeString, getOutputColumnNames, getReversedExprs, getRightAliases, getSkewKeyDefinition, getSkewKeysValuesTables, getSmallKeysDirMap, getStreamAliases, getTagLength, getTagOrder, isFixedAsSorted, isLeftInputJoin, isNoOuterJoin, resetOrder, setAliasToOpInfo, setBaseSrc, setBigKeysDirMap, setConds, setExprs, setFilterMap, setFilters, setFixedAsSorted, setHandleSkewJoin, setKeyTableDesc, setLeftAlias, setNoOuterJoin, setNullSafes, setOutputColumnNames, setQBJoinTreeProps, setQBJoinTreeProps, setReversedExprs, setRightAliases, setSkewKeyDefinition, setSkewKeysValuesTables, setSmallKeysDirMap, setTagOrder, toCompactString

Methods inherited from class org.apache.hadoop.hive.ql.plan.AbstractOperatorDesc

getOpProps, getStatistics, getTraits, getVectorMode, setOpProps, setStatistics, setTraits, setVectorMode

Methods inherited from class java.lang.Object

equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

genJoinKeys

protected boolean genJoinKeys

Constructor Detail

MapJoinDesc

public MapJoinDesc()

MapJoinDesc

public MapJoinDesc(MapJoinDesc clone)

MapJoinDesc

public MapJoinDesc(Map<Byte,List<ExprNodeDesc>> keys,
           TableDesc keyTblDesc,
           Map<Byte,List<ExprNodeDesc>> values,
           List<TableDesc> valueTblDescs,
           List<TableDesc> valueFilteredTblDescs,
           List<String> outputColumnNames,
           int posBigTable,
           JoinCondDesc[] conds,
           Map<Byte,List<ExprNodeDesc>> filters,
           boolean noOuterJoin,
           String dumpFilePrefix)

Method Detail

setVectorDesc

public void setVectorDesc(VectorMapJoinDesc vectorDesc)

getVectorDesc

public VectorMapJoinDesc getVectorDesc()

getParentToInput

public Map<Integer,String> getParentToInput()

setParentToInput

public void setParentToInput(Map<Integer,String> parentToInput)

getParentKeyCounts

public Map<Integer,Long> getParentKeyCounts()

getParentDataSizes

public Map<Integer,Long> getParentDataSizes()

getKeyCountsExplainDesc

public String getKeyCountsExplainDesc()

setParentKeyCount

public void setParentKeyCount(Map<Integer,Long> parentKeyCounts)

getValueIndices

public Map<Byte,int[]> getValueIndices()

setValueIndices

public void setValueIndices(Map<Byte,int[]> valueIndices)

getValueIndex

public int[] getValueIndex(byte alias)

getRetainList

public Map<Byte,List<Integer>> getRetainList()

setRetainList

public void setRetainList(Map<Byte,List<Integer>> retainList)

getDumpFilePrefix

public String getDumpFilePrefix()

Returns:

the dumpFilePrefix

setDumpFilePrefix

public void setDumpFilePrefix(String dumpFilePrefix)

Parameters:

dumpFilePrefix - the dumpFilePrefix to set

getKeysString

public Map<Byte,String> getKeysString()

Overrides:

getKeysString in class JoinDesc

Returns:

the keys in string form

getKeys

public Map<Byte,List<ExprNodeDesc>> getKeys()

Returns:

the keys

setKeys

public void setKeys(Map<Byte,List<ExprNodeDesc>> keys)

Parameters:

keys - the keys to set

getPosBigTable

public int getPosBigTable()

Returns:

the position of the big table not in memory

setPosBigTable

public void setPosBigTable(int posBigTable)

Parameters:

posBigTable - the position of the big table not in memory

getKeyTblDesc

public TableDesc getKeyTblDesc()

Returns:

the keyTblDesc

setKeyTblDesc

public void setKeyTblDesc(TableDesc keyTblDesc)

Parameters:

keyTblDesc - the keyTblDesc to set

getValueFilteredTblDescs

public List<TableDesc> getValueFilteredTblDescs()

setValueFilteredTblDescs

public void setValueFilteredTblDescs(List<TableDesc> valueFilteredTblDescs)

getValueTblDescs

public List<TableDesc> getValueTblDescs()

Returns:

the valueTblDescs

setValueTblDescs

public void setValueTblDescs(List<TableDesc> valueTblDescs)

Parameters:

valueTblDescs - the valueTblDescs to set

getBigTableAlias

public String getBigTableAlias()

Returns:

bigTableAlias

setBigTableAlias

public void setBigTableAlias(String bigTableAlias)

Parameters:

bigTableAlias -

getAliasBucketFileNameMapping

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

setAliasBucketFileNameMapping

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

getBigTableBucketNumMapping

public Map<String,Integer> getBigTableBucketNumMapping()

setBigTableBucketNumMapping

public void setBigTableBucketNumMapping(Map<String,Integer> bigTableBucketNumMapping)

getBigTablePartSpecToFileMapping

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

setBigTablePartSpecToFileMapping

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

isBucketMapJoin

public boolean isBucketMapJoin()

setBucketMapJoin

public void setBucketMapJoin(boolean isBucketMapJoin)

isHybridHashJoin

public boolean isHybridHashJoin()

setHybridHashJoin

public void setHybridHashJoin(boolean isHybridHashJoin)

setHashTableMemoryUsage

public void setHashTableMemoryUsage(float hashtableMemoryUsage)

getHashTableMemoryUsage

public float getHashTableMemoryUsage()

isMapSideJoin

public boolean isMapSideJoin()

Overrides:

isMapSideJoin in class JoinDesc

setGenJoinKeys

public void setGenJoinKeys(boolean genJoinKeys)

getGenJoinKeys

public boolean getGenJoinKeys()