public class JoinDesc extends AbstractOperatorDesc
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 java.util.List<java.lang.String> |
outputColumnNames |
static int |
RIGHT_OUTER_JOIN |
protected java.lang.Byte[] |
tagOrder |
static int |
UNIQUE_JOIN |
Constructor and Description |
---|
JoinDesc() |
JoinDesc(JoinDesc clone) |
JoinDesc(java.util.Map<java.lang.Byte,java.util.List<ExprNodeDesc>> exprs,
java.util.List<java.lang.String> outputColumnNames) |
JoinDesc(java.util.Map<java.lang.Byte,java.util.List<ExprNodeDesc>> exprs,
java.util.List<java.lang.String> outputColumnNames,
boolean noOuterJoin,
JoinCondDesc[] conds) |
JoinDesc(java.util.Map<java.lang.Byte,java.util.List<ExprNodeDesc>> exprs,
java.util.List<java.lang.String> outputColumnNames,
boolean noOuterJoin,
JoinCondDesc[] conds,
java.util.Map<java.lang.Byte,java.util.List<ExprNodeDesc>> filters) |
JoinDesc(java.util.Map<java.lang.Byte,java.util.List<ExprNodeDesc>> exprs,
java.util.List<java.lang.String> outputColumnNames,
JoinCondDesc[] conds) |
Modifier and Type | Method and Description |
---|---|
java.lang.Object |
clone() |
<T> T[] |
convertToArray(java.util.Map<java.lang.Byte,T> source,
java.lang.Class<T> compType) |
java.util.Map<java.lang.Byte,java.lang.String> |
getBigKeysDirMap() |
JoinCondDesc[] |
getConds() |
java.util.List<JoinCondDesc> |
getCondsList() |
java.util.Map<java.lang.Byte,java.util.List<ExprNodeDesc>> |
getExprs() |
java.util.Map<java.lang.Byte,java.lang.String> |
getExprsStringMap() |
int[][] |
getFilterMap() |
java.util.Map<java.lang.Integer,java.lang.String> |
getFilterMapString() |
java.util.Map<java.lang.Byte,java.util.List<ExprNodeDesc>> |
getFilters() |
java.util.Map<java.lang.Byte,java.lang.String> |
getFiltersStringMap()
Get the string representation of filters.
|
boolean |
getHandleSkewJoin() |
TableDesc |
getKeyTableDesc() |
boolean |
getNoOuterJoin() |
boolean[] |
getNullSafes() |
java.lang.String |
getNullSafeString() |
java.util.List<java.lang.String> |
getOutputColumnNames() |
java.util.Map<java.lang.String,java.lang.Byte> |
getReversedExprs() |
int |
getSkewKeyDefinition() |
java.util.Map<java.lang.Byte,TableDesc> |
getSkewKeysValuesTables() |
java.util.Map<java.lang.Byte,java.util.Map<java.lang.Byte,java.lang.String>> |
getSmallKeysDirMap() |
int |
getTagLength() |
java.lang.Byte[] |
getTagOrder()
The order in which tables should be processed when joining.
|
boolean |
isFixedAsSorted() |
boolean |
isNoOuterJoin() |
void |
resetOrder() |
void |
setBigKeysDirMap(java.util.Map<java.lang.Byte,java.lang.String> bigKeysDirMap)
set the mapping from tbl to dir for big keys.
|
void |
setConds(JoinCondDesc[] conds) |
void |
setExprs(java.util.Map<java.lang.Byte,java.util.List<ExprNodeDesc>> exprs) |
void |
setFilterMap(int[][] filterMap) |
void |
setFilters(java.util.Map<java.lang.Byte,java.util.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 |
setNoOuterJoin(boolean noOuterJoin) |
void |
setNullSafes(boolean[] nullSafes) |
void |
setOutputColumnNames(java.util.List<java.lang.String> outputColumnNames) |
void |
setReversedExprs(java.util.Map<java.lang.String,java.lang.Byte> reversedExprs) |
void |
setSkewKeyDefinition(int skewKeyDefinition)
set skew key definition.
|
void |
setSkewKeysValuesTables(java.util.Map<java.lang.Byte,TableDesc> skewKeysValuesTables) |
void |
setSmallKeysDirMap(java.util.Map<java.lang.Byte,java.util.Map<java.lang.Byte,java.lang.String>> smallKeysDirMap)
set the mapping from tbl to dir for small keys.
|
void |
setTagOrder(java.lang.Byte[] tagOrder)
The order in which tables should be processed when joining.
|
protected java.util.Map<java.lang.Integer,java.lang.String> |
toCompactString(int[][] filterMap) |
public static final int INNER_JOIN
public static final int LEFT_OUTER_JOIN
public static final int RIGHT_OUTER_JOIN
public static final int FULL_OUTER_JOIN
public static final int UNIQUE_JOIN
public static final int LEFT_SEMI_JOIN
protected java.util.List<java.lang.String> outputColumnNames
protected boolean noOuterJoin
protected JoinCondDesc[] conds
protected java.lang.Byte[] tagOrder
public JoinDesc()
public JoinDesc(java.util.Map<java.lang.Byte,java.util.List<ExprNodeDesc>> exprs, java.util.List<java.lang.String> outputColumnNames, boolean noOuterJoin, JoinCondDesc[] conds, java.util.Map<java.lang.Byte,java.util.List<ExprNodeDesc>> filters)
public JoinDesc(java.util.Map<java.lang.Byte,java.util.List<ExprNodeDesc>> exprs, java.util.List<java.lang.String> outputColumnNames, boolean noOuterJoin, JoinCondDesc[] conds)
public JoinDesc(java.util.Map<java.lang.Byte,java.util.List<ExprNodeDesc>> exprs, java.util.List<java.lang.String> outputColumnNames)
public JoinDesc(java.util.Map<java.lang.Byte,java.util.List<ExprNodeDesc>> exprs, java.util.List<java.lang.String> outputColumnNames, JoinCondDesc[] conds)
public JoinDesc(JoinDesc clone)
public void resetOrder()
public java.lang.Object clone()
clone
in interface OperatorDesc
clone
in class AbstractOperatorDesc
public java.util.Map<java.lang.Byte,java.util.List<ExprNodeDesc>> getExprs()
public java.util.Map<java.lang.String,java.lang.Byte> getReversedExprs()
public void setReversedExprs(java.util.Map<java.lang.String,java.lang.Byte> reversedExprs)
public java.util.Map<java.lang.Byte,java.lang.String> getExprsStringMap()
public void setExprs(java.util.Map<java.lang.Byte,java.util.List<ExprNodeDesc>> exprs)
public java.util.Map<java.lang.Byte,java.lang.String> getFiltersStringMap()
public java.util.Map<java.lang.Byte,java.util.List<ExprNodeDesc>> getFilters()
public void setFilters(java.util.Map<java.lang.Byte,java.util.List<ExprNodeDesc>> filters)
public java.util.List<java.lang.String> getOutputColumnNames()
public void setOutputColumnNames(java.util.List<java.lang.String> outputColumnNames)
public boolean getNoOuterJoin()
public void setNoOuterJoin(boolean noOuterJoin)
public java.util.List<JoinCondDesc> getCondsList()
public JoinCondDesc[] getConds()
public void setConds(JoinCondDesc[] conds)
public java.lang.Byte[] getTagOrder()
public void setTagOrder(java.lang.Byte[] tagOrder)
tagOrder
- Array of tagspublic boolean getHandleSkewJoin()
public void setHandleSkewJoin(boolean handleSkewJoin)
handleSkewJoin
- public java.util.Map<java.lang.Byte,java.lang.String> getBigKeysDirMap()
public void setBigKeysDirMap(java.util.Map<java.lang.Byte,java.lang.String> bigKeysDirMap)
bigKeysDirMap
- public java.util.Map<java.lang.Byte,java.util.Map<java.lang.Byte,java.lang.String>> getSmallKeysDirMap()
public void setSmallKeysDirMap(java.util.Map<java.lang.Byte,java.util.Map<java.lang.Byte,java.lang.String>> smallKeysDirMap)
smallKeysDirMap
- public int getSkewKeyDefinition()
public void setSkewKeyDefinition(int skewKeyDefinition)
skewKeyDefinition
- public java.util.Map<java.lang.Byte,TableDesc> getSkewKeysValuesTables()
public void setSkewKeysValuesTables(java.util.Map<java.lang.Byte,TableDesc> skewKeysValuesTables)
skewKeysValuesTables
- set the table desc for storing skew keys and their corresponding
value;public boolean isNoOuterJoin()
public void setKeyTableDesc(TableDesc keyTblDesc)
public TableDesc getKeyTableDesc()
public boolean[] getNullSafes()
public void setNullSafes(boolean[] nullSafes)
public java.lang.String getNullSafeString()
public int[][] getFilterMap()
public void setFilterMap(int[][] filterMap)
public java.util.Map<java.lang.Integer,java.lang.String> getFilterMapString()
protected java.util.Map<java.lang.Integer,java.lang.String> toCompactString(int[][] filterMap)
public int getTagLength()
public <T> T[] convertToArray(java.util.Map<java.lang.Byte,T> source, java.lang.Class<T> compType)
public boolean isFixedAsSorted()
public void setFixedAsSorted(boolean fixedAsSorted)
Copyright © 2012 The Apache Software Foundation