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

conds, FULL_OUTER_JOIN, INNER_JOIN, LEFT_OUTER_JOIN, LEFT_SEMI_JOIN, noOuterJoin, outputColumnNames, RIGHT_OUTER_JOIN, tagOrder, 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()
String	getDumpFilePrefix()
Map<Byte,List<ExprNodeDesc>>	getKeys()
TableDesc	getKeyTblDesc()
int	getPosBigTable()
Map<Byte,List<Integer>>	getRetainList()
List<TableDesc>	getValueFilteredTblDescs()
List<TableDesc>	getValueTblDescs()
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	setDumpFilePrefix(String dumpFilePrefix)
void	setKeys(Map<Byte,List<ExprNodeDesc>> keys)
void	setKeyTblDesc(TableDesc keyTblDesc)
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, getBigKeysDirMap, getConds, getCondsList, getExprs, getExprsStringMap, getFilterMap, getFilterMapString, getFilters, getFiltersStringMap, getHandleSkewJoin, getKeyTableDesc, getNoOuterJoin, getNullSafes, getNullSafeString, getOutputColumnNames, getReversedExprs, getSkewKeyDefinition, getSkewKeysValuesTables, getSmallKeysDirMap, getTagOrder, isNoOuterJoin, setBigKeysDirMap, setConds, setExprs, setFilterMap, setFilters, setHandleSkewJoin, setKeyTableDesc, setNoOuterJoin, setNullSafes, setOutputColumnNames, setReversedExprs, setSkewKeyDefinition, setSkewKeysValuesTables, setSmallKeysDirMap, setTagOrder, toCompactString

Methods inherited from class java.lang.Object

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

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

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)