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:

SMBJoinDesc

public class MapJoinDesc
extends JoinDesc
implements Serializable

Map Join operator Descriptor implementation.

See Also:

Serialized Form

Field Summary

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

FULL_OUTER_JOIN, INNER_JOIN, LEFT_OUTER_JOIN, LEFT_SEMI_JOIN, RIGHT_OUTER_JOIN, UNIQUE_JOIN

Constructor Summary

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

Map<String,Map<String,List<String>>>	getAliasBucketFileNameMapping()
String	getBigTableAlias()
Map<String,Integer>	getBigTableBucketNumMapping()
Map<String,List<String>>	getBigTablePartSpecToFileMapping()
boolean	getCustomBucketMapJoin()
String	getDumpFilePrefix()
float	getHashTableMemoryUsage()
Map<Byte,List<ExprNodeDesc>>	getKeys()
Map<Byte,String>	getKeysString()
TableDesc	getKeyTblDesc()
Map<Integer,String>	getParentToInput()
int	getPosBigTable()
Map<Byte,List<Integer>>	getRetainList()
List<TableDesc>	getValueFilteredTblDescs()
List<TableDesc>	getValueTblDescs()
boolean	isBucketMapJoin()
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	setCustomBucketMapJoin(boolean customBucketMapJoin)
void	setDumpFilePrefix(String dumpFilePrefix)
void	setHashTableMemoryUsage(float hashtableMemoryUsage)
void	setKeys(Map<Byte,List<ExprNodeDesc>> keys)
void	setKeyTblDesc(TableDesc keyTblDesc)
void	setParentToInput(Map<Integer,String> parentToInput)
void	setPosBigTable(int posBigTable)
void	setRetainList(Map<Byte,List<Integer>> retainList)
void	setValueFilteredTblDescs(List<TableDesc> valueFilteredTblDescs)
void	setValueTblDescs(List<TableDesc> valueTblDescs)

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

clone, convertToArray, getBigKeysDirMap, getConds, getCondsList, getExprs, getExprsStringMap, getFilterMap, getFilterMapString, getFilters, getFiltersStringMap, getHandleSkewJoin, getKeyTableDesc, getNoOuterJoin, getNullSafes, getNullSafeString, getOutputColumnNames, getReversedExprs, getSkewKeyDefinition, getSkewKeysValuesTables, getSmallKeysDirMap, getTagLength, getTagOrder, isFixedAsSorted, isNoOuterJoin, resetOrder, setBigKeysDirMap, setConds, setExprs, setFilterMap, setFilters, setFixedAsSorted, setHandleSkewJoin, setKeyTableDesc, setNoOuterJoin, setNullSafes, setOutputColumnNames, setReversedExprs, setSkewKeyDefinition, setSkewKeysValuesTables, setSmallKeysDirMap, setTagOrder

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

getOpTraits, getStatistics, setOpTraits, setStatistics, setVectorMode

Methods inherited from class java.lang.Object

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

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

getParentToInput

public Map<Integer,String> getParentToInput()

setParentToInput

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

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()

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)

setHashTableMemoryUsage

public void setHashTableMemoryUsage(float hashtableMemoryUsage)

getHashTableMemoryUsage

public float getHashTableMemoryUsage()

setCustomBucketMapJoin

public void setCustomBucketMapJoin(boolean customBucketMapJoin)

getCustomBucketMapJoin

public boolean getCustomBucketMapJoin()