|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object org.apache.hadoop.hive.ql.plan.AbstractOperatorDesc org.apache.hadoop.hive.ql.plan.JoinDesc
public class JoinDesc
Join operator Descriptor implementation.
Field Summary | |
---|---|
static int |
FULL_OUTER_JOIN
|
static int |
INNER_JOIN
|
static int |
LEFT_OUTER_JOIN
|
static int |
LEFT_SEMI_JOIN
|
static int |
RIGHT_OUTER_JOIN
|
static int |
UNIQUE_JOIN
|
Constructor Summary | |
---|---|
JoinDesc()
|
|
JoinDesc(JoinDesc clone)
|
|
JoinDesc(Map<Byte,List<ExprNodeDesc>> exprs,
List<String> outputColumnNames)
|
|
JoinDesc(Map<Byte,List<ExprNodeDesc>> exprs,
List<String> outputColumnNames,
boolean noOuterJoin,
JoinCondDesc[] conds)
|
|
JoinDesc(Map<Byte,List<ExprNodeDesc>> exprs,
List<String> outputColumnNames,
boolean noOuterJoin,
JoinCondDesc[] conds,
Map<Byte,List<ExprNodeDesc>> filters)
|
|
JoinDesc(Map<Byte,List<ExprNodeDesc>> exprs,
List<String> outputColumnNames,
JoinCondDesc[] conds)
|
Method Summary | ||
---|---|---|
Object |
clone()
|
|
|
convertToArray(Map<Byte,T> source,
Class<T> compType)
|
|
Map<Byte,org.apache.hadoop.fs.Path> |
getBigKeysDirMap()
|
|
JoinCondDesc[] |
getConds()
|
|
List<JoinCondDesc> |
getCondsList()
|
|
Map<Byte,List<ExprNodeDesc>> |
getExprs()
|
|
Map<Byte,String> |
getExprsStringMap()
|
|
int[][] |
getFilterMap()
|
|
Map<Integer,String> |
getFilterMapString()
|
|
Map<Byte,List<ExprNodeDesc>> |
getFilters()
|
|
Map<Byte,String> |
getFiltersStringMap()
Get the string representation of filters. |
|
boolean |
getHandleSkewJoin()
|
|
TableDesc |
getKeyTableDesc()
|
|
boolean |
getNoOuterJoin()
|
|
boolean[] |
getNullSafes()
|
|
String |
getNullSafeString()
|
|
List<String> |
getOutputColumnNames()
|
|
Map<String,Byte> |
getReversedExprs()
|
|
int |
getSkewKeyDefinition()
|
|
Map<Byte,TableDesc> |
getSkewKeysValuesTables()
|
|
Map<Byte,Map<Byte,org.apache.hadoop.fs.Path>> |
getSmallKeysDirMap()
|
|
int |
getTagLength()
|
|
Byte[] |
getTagOrder()
The order in which tables should be processed when joining. |
|
boolean |
isFixedAsSorted()
|
|
boolean |
isNoOuterJoin()
|
|
void |
resetOrder()
|
|
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 |
setNoOuterJoin(boolean noOuterJoin)
|
|
void |
setNullSafes(boolean[] nullSafes)
|
|
void |
setOutputColumnNames(List<String> outputColumnNames)
|
|
void |
setReversedExprs(Map<String,Byte> reversedExprs)
|
|
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. |
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 |
Field Detail |
---|
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
Constructor Detail |
---|
public JoinDesc()
public JoinDesc(Map<Byte,List<ExprNodeDesc>> exprs, List<String> outputColumnNames, boolean noOuterJoin, JoinCondDesc[] conds, Map<Byte,List<ExprNodeDesc>> filters)
public JoinDesc(Map<Byte,List<ExprNodeDesc>> exprs, List<String> outputColumnNames, boolean noOuterJoin, JoinCondDesc[] conds)
public JoinDesc(Map<Byte,List<ExprNodeDesc>> exprs, List<String> outputColumnNames)
public JoinDesc(Map<Byte,List<ExprNodeDesc>> exprs, List<String> outputColumnNames, JoinCondDesc[] conds)
public JoinDesc(JoinDesc clone)
Method Detail |
---|
public void resetOrder()
public Object clone()
clone
in interface OperatorDesc
clone
in class AbstractOperatorDesc
public Map<Byte,List<ExprNodeDesc>> getExprs()
public Map<String,Byte> getReversedExprs()
public void setReversedExprs(Map<String,Byte> reversedExprs)
public Map<Byte,String> getExprsStringMap()
public void setExprs(Map<Byte,List<ExprNodeDesc>> exprs)
public Map<Byte,String> getFiltersStringMap()
public Map<Byte,List<ExprNodeDesc>> getFilters()
public void setFilters(Map<Byte,List<ExprNodeDesc>> filters)
public List<String> getOutputColumnNames()
public void setOutputColumnNames(List<String> outputColumnNames)
public boolean getNoOuterJoin()
public void setNoOuterJoin(boolean noOuterJoin)
public List<JoinCondDesc> getCondsList()
public JoinCondDesc[] getConds()
public void setConds(JoinCondDesc[] conds)
public Byte[] getTagOrder()
public void setTagOrder(Byte[] tagOrder)
tagOrder
- Array of tagspublic boolean getHandleSkewJoin()
public void setHandleSkewJoin(boolean handleSkewJoin)
handleSkewJoin
- public Map<Byte,org.apache.hadoop.fs.Path> getBigKeysDirMap()
public void setBigKeysDirMap(Map<Byte,org.apache.hadoop.fs.Path> bigKeysDirMap)
bigKeysDirMap
- public Map<Byte,Map<Byte,org.apache.hadoop.fs.Path>> getSmallKeysDirMap()
public void setSmallKeysDirMap(Map<Byte,Map<Byte,org.apache.hadoop.fs.Path>> smallKeysDirMap)
smallKeysDirMap
- public int getSkewKeyDefinition()
public void setSkewKeyDefinition(int skewKeyDefinition)
skewKeyDefinition
- public Map<Byte,TableDesc> getSkewKeysValuesTables()
public void setSkewKeysValuesTables(Map<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 String getNullSafeString()
public int[][] getFilterMap()
public void setFilterMap(int[][] filterMap)
public Map<Integer,String> getFilterMapString()
public int getTagLength()
public <T> T[] convertToArray(Map<Byte,T> source, Class<T> compType)
public boolean isFixedAsSorted()
public void setFixedAsSorted(boolean fixedAsSorted)
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |