org.apache.hadoop.hive.ql.plan

Class JoinDesc

java.lang.Object

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

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

All Implemented Interfaces:

Serializable, Cloneable, OperatorDesc

Direct Known Subclasses:

HashTableSinkDesc, MapJoinDesc

public class JoinDesc
extends AbstractOperatorDesc

Join operator Descriptor implementation.

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
protected JoinCondDesc[]	conds
static int	FULL_OUTER_JOIN
static int	INNER_JOIN
static int	LEFT_OUTER_JOIN
static int	LEFT_SEMI_JOIN
protected boolean	noOuterJoin
protected List<String>	outputColumnNames
static int	RIGHT_OUTER_JOIN
protected Byte[]	tagOrder
static int	UNIQUE_JOIN

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

opProps, opTraits, statistics, vectorMode

Constructor Summary

Constructors

Constructor and Description
JoinDesc()
JoinDesc(JoinDesc clone)
JoinDesc(Map<Byte,List<ExprNodeDesc>> exprs, List<String> outputColumnNames, boolean noOuterJoin, JoinCondDesc[] conds, ExprNodeDesc[][] joinKeys)
JoinDesc(Map<Byte,List<ExprNodeDesc>> exprs, List<String> outputColumnNames, boolean noOuterJoin, JoinCondDesc[] conds, Map<Byte,List<ExprNodeDesc>> filters, ExprNodeDesc[][] joinKeys)

Method Summary

Methods

Modifier and Type	Method and Description
Object	clone()
void	cloneQBJoinTreeProps(JoinDesc joinDesc)
<T> T[]	convertToArray(Map<Byte,T> source, Class<T> compType)
Map<String,Operator<? extends OperatorDesc>>	getAliasToOpInfo()
String[]	getBaseSrc()
Map<Byte,org.apache.hadoop.fs.Path>	getBigKeysDirMap()
JoinCondDesc[]	getConds()
List<JoinCondDesc>	getCondsList()
Map<Byte,List<ExprNodeDesc>>	getExprs()
int[][]	getFilterMap()
Map<Integer,String>	getFilterMapString()
Map<Byte,List<ExprNodeDesc>>	getFilters()
Map<Byte,String>	getFiltersStringMap() Get the string representation of filters.
boolean	getHandleSkewJoin()
String	getId()
Map<Byte,String>	getKeysString()
TableDesc	getKeyTableDesc()
String	getLeftAlias()
String[]	getLeftAliases()
List<String>	getMapAliases()
boolean	getNoOuterJoin()
boolean[]	getNullSafes()
String	getNullSafeString()
List<String>	getOutputColumnNames()
Map<String,Byte>	getReversedExprs()
String[]	getRightAliases()
int	getSkewKeyDefinition()
Map<Byte,TableDesc>	getSkewKeysValuesTables()
Map<Byte,Map<Byte,org.apache.hadoop.fs.Path>>	getSmallKeysDirMap()
List<String>	getStreamAliases()
int	getTagLength()
Byte[]	getTagOrder() The order in which tables should be processed when joining.
boolean	isFixedAsSorted()
boolean	isLeftInputJoin()
boolean	isMapSideJoin()
boolean	isNoOuterJoin()
void	resetOrder()
void	setAliasToOpInfo(Map<String,Operator<? extends OperatorDesc>> aliasToOpInfo)
void	setBaseSrc(String[] baseSrc)
void	setBigKeysDirMap(Map<Byte,org.apache.hadoop.fs.Path> bigKeysDirMap) set the mapping from tbl to dir for big keys.
void	setConds(JoinCondDesc[] conds)
void	setExprs(Map<Byte,List<ExprNodeDesc>> exprs)
void	setFilterMap(int[][] filterMap)
void	setFilters(Map<Byte,List<ExprNodeDesc>> filters)
void	setFixedAsSorted(boolean fixedAsSorted)
void	setHandleSkewJoin(boolean handleSkewJoin) set to handle skew join in this join op.
void	setKeyTableDesc(TableDesc keyTblDesc)
void	setLeftAlias(String leftAlias)
void	setNoOuterJoin(boolean noOuterJoin)
void	setNullSafes(boolean[] nullSafes)
void	setOutputColumnNames(List<String> outputColumnNames)
void	setQBJoinTreeProps(JoinDesc joinDesc)
void	setQBJoinTreeProps(QBJoinTree joinTree)
void	setReversedExprs(Map<String,Byte> reversedExprs)
void	setRightAliases(String[] rightAliases)
void	setSkewKeyDefinition(int skewKeyDefinition) set skew key definition.
void	setSkewKeysValuesTables(Map<Byte,TableDesc> skewKeysValuesTables)
void	setSmallKeysDirMap(Map<Byte,Map<Byte,org.apache.hadoop.fs.Path>> smallKeysDirMap) set the mapping from tbl to dir for small keys.
void	setTagOrder(Byte[] tagOrder) The order in which tables should be processed when joining.
protected Map<Integer,String>	toCompactString(int[][] filterMap)

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

INNER_JOIN

public static final int INNER_JOIN

See Also:

Constant Field Values

LEFT_OUTER_JOIN

public static final int LEFT_OUTER_JOIN

See Also:

Constant Field Values

RIGHT_OUTER_JOIN

public static final int RIGHT_OUTER_JOIN

See Also:

Constant Field Values

FULL_OUTER_JOIN

public static final int FULL_OUTER_JOIN

See Also:

Constant Field Values

UNIQUE_JOIN

public static final int UNIQUE_JOIN

See Also:

Constant Field Values

LEFT_SEMI_JOIN

public static final int LEFT_SEMI_JOIN

See Also:

Constant Field Values

outputColumnNames

protected List<String> outputColumnNames

noOuterJoin

protected boolean noOuterJoin

conds

protected JoinCondDesc[] conds

tagOrder

protected Byte[] tagOrder

Constructor Detail

JoinDesc

public JoinDesc()

JoinDesc

public JoinDesc(Map<Byte,List<ExprNodeDesc>> exprs,
        List<String> outputColumnNames,
        boolean noOuterJoin,
        JoinCondDesc[] conds,
        ExprNodeDesc[][] joinKeys)

JoinDesc

public JoinDesc(Map<Byte,List<ExprNodeDesc>> exprs,
        List<String> outputColumnNames,
        boolean noOuterJoin,
        JoinCondDesc[] conds,
        Map<Byte,List<ExprNodeDesc>> filters,
        ExprNodeDesc[][] joinKeys)

JoinDesc

public JoinDesc(JoinDesc clone)

Method Detail

resetOrder

public void resetOrder()

clone

public Object clone()

Specified by:

clone in interface OperatorDesc

Overrides:

clone in class AbstractOperatorDesc

getExprs

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

getReversedExprs

public Map<String,Byte> getReversedExprs()

setReversedExprs

public void setReversedExprs(Map<String,Byte> reversedExprs)

getKeysString

public Map<Byte,String> getKeysString()

Returns:

the keys in string form

setExprs

public void setExprs(Map<Byte,List<ExprNodeDesc>> exprs)

getFiltersStringMap

public Map<Byte,String> getFiltersStringMap()

Get the string representation of filters. Returns null if they are no filters.

Returns:

Map from alias to filters on the alias.

getFilters

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

setFilters

public void setFilters(Map<Byte,List<ExprNodeDesc>> filters)

getOutputColumnNames

public List<String> getOutputColumnNames()

setOutputColumnNames

public void setOutputColumnNames(List<String> outputColumnNames)

getNoOuterJoin

public boolean getNoOuterJoin()

setNoOuterJoin

public void setNoOuterJoin(boolean noOuterJoin)

getCondsList

public List<JoinCondDesc> getCondsList()

getConds

public JoinCondDesc[] getConds()

setConds

public void setConds(JoinCondDesc[] conds)

getTagOrder

public Byte[] getTagOrder()

The order in which tables should be processed when joining.

Returns:

Array of tags

setTagOrder

public void setTagOrder(Byte[] tagOrder)

The order in which tables should be processed when joining.

Parameters:

tagOrder - Array of tags

getHandleSkewJoin

public boolean getHandleSkewJoin()

setHandleSkewJoin

public void setHandleSkewJoin(boolean handleSkewJoin)

set to handle skew join in this join op.

Parameters:

handleSkewJoin -

getBigKeysDirMap

public Map<Byte,org.apache.hadoop.fs.Path> getBigKeysDirMap()

Returns:

mapping from tbl to dir for big keys.

setBigKeysDirMap

public void setBigKeysDirMap(Map<Byte,org.apache.hadoop.fs.Path> bigKeysDirMap)

set the mapping from tbl to dir for big keys.

Parameters:

bigKeysDirMap -

getSmallKeysDirMap

public Map<Byte,Map<Byte,org.apache.hadoop.fs.Path>> getSmallKeysDirMap()

Returns:

mapping from tbl to dir for small keys

setSmallKeysDirMap

public void setSmallKeysDirMap(Map<Byte,Map<Byte,org.apache.hadoop.fs.Path>> smallKeysDirMap)

set the mapping from tbl to dir for small keys.

Parameters:

smallKeysDirMap -

getSkewKeyDefinition

public int getSkewKeyDefinition()

Returns:

skew key definition. If we see a key's associated entries' number is bigger than this, we will define this key as a skew key.

setSkewKeyDefinition

public void setSkewKeyDefinition(int skewKeyDefinition)

set skew key definition.

Parameters:

skewKeyDefinition -

getSkewKeysValuesTables

public Map<Byte,TableDesc> getSkewKeysValuesTables()

Returns:

the table desc for storing skew keys and their corresponding value;

setSkewKeysValuesTables

public void setSkewKeysValuesTables(Map<Byte,TableDesc> skewKeysValuesTables)

Parameters:

skewKeysValuesTables - set the table desc for storing skew keys and their corresponding value;

isNoOuterJoin

public boolean isNoOuterJoin()

setKeyTableDesc

public void setKeyTableDesc(TableDesc keyTblDesc)

getKeyTableDesc

public TableDesc getKeyTableDesc()

getNullSafes

public boolean[] getNullSafes()

setNullSafes

public void setNullSafes(boolean[] nullSafes)

getNullSafeString

public String getNullSafeString()

getFilterMap

public int[][] getFilterMap()

setFilterMap

public void setFilterMap(int[][] filterMap)

getFilterMapString

public Map<Integer,String> getFilterMapString()

toCompactString

protected Map<Integer,String> toCompactString(int[][] filterMap)

getTagLength

public int getTagLength()

convertToArray

public <T> T[] convertToArray(Map<Byte,T> source,
                     Class<T> compType)

isFixedAsSorted

public boolean isFixedAsSorted()

setFixedAsSorted

public void setFixedAsSorted(boolean fixedAsSorted)

getLeftAliases

public String[] getLeftAliases()

getBaseSrc

public String[] getBaseSrc()

setBaseSrc

public void setBaseSrc(String[] baseSrc)

getId

public String getId()

getMapAliases

public List<String> getMapAliases()

getAliasToOpInfo

public Map<String,Operator<? extends OperatorDesc>> getAliasToOpInfo()

setAliasToOpInfo

public void setAliasToOpInfo(Map<String,Operator<? extends OperatorDesc>> aliasToOpInfo)

isLeftInputJoin

public boolean isLeftInputJoin()

getLeftAlias

public String getLeftAlias()

setLeftAlias

public void setLeftAlias(String leftAlias)

getRightAliases

public String[] getRightAliases()

setRightAliases

public void setRightAliases(String[] rightAliases)

getStreamAliases

public List<String> getStreamAliases()

isMapSideJoin

public boolean isMapSideJoin()

setQBJoinTreeProps

public void setQBJoinTreeProps(JoinDesc joinDesc)

setQBJoinTreeProps

public void setQBJoinTreeProps(QBJoinTree joinTree)

cloneQBJoinTreeProps

public void cloneQBJoinTreeProps(JoinDesc joinDesc)