public class HashTableSinkDesc extends JoinDesc implements java.io.Serializable
Modifier and Type | Field and Description |
---|---|
protected JoinCondDesc[] |
conds |
protected boolean |
noOuterJoin |
protected java.util.List<java.lang.String> |
outputColumnNames |
protected java.lang.Byte[] |
tagOrder |
FULL_OUTER_JOIN, INNER_JOIN, LEFT_OUTER_JOIN, LEFT_SEMI_JOIN, RIGHT_OUTER_JOIN, UNIQUE_JOIN
Constructor and Description |
---|
HashTableSinkDesc() |
HashTableSinkDesc(MapJoinDesc clone) |
Modifier and Type | Method and Description |
---|---|
java.util.Map<java.lang.Byte,java.lang.String> |
getBigKeysDirMap() |
BucketMapJoinContext |
getBucketMapjoinContext() |
JoinCondDesc[] |
getConds() |
java.lang.String |
getDumpFilePrefix() |
java.util.Map<java.lang.Byte,java.util.List<ExprNodeDesc>> |
getExprs() |
int[][] |
getFilterMap() |
java.util.Map<java.lang.Integer,java.lang.String> |
getFilterMapString() |
java.util.Map<java.lang.Byte,java.util.List<ExprNodeDesc>> |
getFilters() |
float |
getHashtableMemoryUsage() |
java.util.Map<java.lang.Byte,java.util.List<ExprNodeDesc>> |
getKeys() |
TableDesc |
getKeyTableDesc() |
TableDesc |
getKeyTblDesc() |
java.util.List<java.lang.String> |
getOutputColumnNames() |
int |
getPosBigTable() |
java.util.Map<java.lang.Byte,java.util.List<java.lang.Integer>> |
getRetainList() |
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() |
java.lang.Byte[] |
getTagOrder()
The order in which tables should be processed when joining.
|
java.util.List<TableDesc> |
getValueTblDescs() |
java.util.List<TableDesc> |
getValueTblFilteredDescs() |
boolean |
isHandleSkewJoin() |
boolean |
isNoOuterJoin() |
void |
setBigKeysDirMap(java.util.Map<java.lang.Byte,java.lang.String> bigKeysDirMap)
set the mapping from tbl to dir for big keys.
|
void |
setBucketMapjoinContext(BucketMapJoinContext bucketMapjoinContext) |
void |
setConds(JoinCondDesc[] conds) |
void |
setDumpFilePrefix(java.lang.String dumpFilePrefix) |
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 |
setHandleSkewJoin(boolean handleSkewJoin)
set to handle skew join in this join op.
|
void |
setHashtableMemoryUsage(float hashtableMemoryUsage) |
void |
setKeys(java.util.Map<java.lang.Byte,java.util.List<ExprNodeDesc>> keys) |
void |
setKeyTableDesc(TableDesc keyTableDesc) |
void |
setKeyTblDesc(TableDesc keyTblDesc) |
void |
setNoOuterJoin(boolean noOuterJoin) |
void |
setOutputColumnNames(java.util.List<java.lang.String> outputColumnNames) |
void |
setPosBigTable(int posBigTable) |
void |
setRetainList(java.util.Map<java.lang.Byte,java.util.List<java.lang.Integer>> retainList) |
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.
|
void |
setValueTblDescs(java.util.List<TableDesc> valueTblDescs) |
void |
setValueTblFilteredDescs(java.util.List<TableDesc> valueTblFilteredDescs) |
clone, convertToArray, getCondsList, getExprsStringMap, getFiltersStringMap, getHandleSkewJoin, getNoOuterJoin, getNullSafes, getNullSafeString, getTagLength, isFixedAsSorted, resetOrder, setFixedAsSorted, setNullSafes, toCompactString
protected java.util.List<java.lang.String> outputColumnNames
protected boolean noOuterJoin
protected JoinCondDesc[] conds
protected java.lang.Byte[] tagOrder
public HashTableSinkDesc()
public HashTableSinkDesc(MapJoinDesc clone)
public float getHashtableMemoryUsage()
public void setHashtableMemoryUsage(float hashtableMemoryUsage)
public java.lang.String getDumpFilePrefix()
public void setDumpFilePrefix(java.lang.String dumpFilePrefix)
dumpFilePrefix
- the dumpFilePrefix to setpublic boolean isHandleSkewJoin()
public void setHandleSkewJoin(boolean handleSkewJoin)
JoinDesc
setHandleSkewJoin
in class JoinDesc
public int getSkewKeyDefinition()
getSkewKeyDefinition
in class JoinDesc
public void setSkewKeyDefinition(int skewKeyDefinition)
JoinDesc
setSkewKeyDefinition
in class JoinDesc
public java.util.Map<java.lang.Byte,java.lang.String> getBigKeysDirMap()
getBigKeysDirMap
in class JoinDesc
public void setBigKeysDirMap(java.util.Map<java.lang.Byte,java.lang.String> bigKeysDirMap)
JoinDesc
setBigKeysDirMap
in class JoinDesc
public java.util.Map<java.lang.Byte,java.util.Map<java.lang.Byte,java.lang.String>> getSmallKeysDirMap()
getSmallKeysDirMap
in class JoinDesc
public void setSmallKeysDirMap(java.util.Map<java.lang.Byte,java.util.Map<java.lang.Byte,java.lang.String>> smallKeysDirMap)
JoinDesc
setSmallKeysDirMap
in class JoinDesc
public java.util.Map<java.lang.Byte,TableDesc> getSkewKeysValuesTables()
getSkewKeysValuesTables
in class JoinDesc
public void setSkewKeysValuesTables(java.util.Map<java.lang.Byte,TableDesc> skewKeysValuesTables)
setSkewKeysValuesTables
in class JoinDesc
skewKeysValuesTables
- set the table desc for storing skew keys and their corresponding
value;public java.util.Map<java.lang.Byte,java.util.List<ExprNodeDesc>> getExprs()
public void setExprs(java.util.Map<java.lang.Byte,java.util.List<ExprNodeDesc>> exprs)
public java.util.Map<java.lang.Byte,java.util.List<ExprNodeDesc>> getFilters()
getFilters
in class JoinDesc
public java.util.List<TableDesc> getValueTblFilteredDescs()
public void setValueTblFilteredDescs(java.util.List<TableDesc> valueTblFilteredDescs)
public void setFilters(java.util.Map<java.lang.Byte,java.util.List<ExprNodeDesc>> filters)
setFilters
in class JoinDesc
public java.util.List<java.lang.String> getOutputColumnNames()
getOutputColumnNames
in class JoinDesc
public void setOutputColumnNames(java.util.List<java.lang.String> outputColumnNames)
setOutputColumnNames
in class JoinDesc
public java.util.Map<java.lang.String,java.lang.Byte> getReversedExprs()
getReversedExprs
in class JoinDesc
public void setReversedExprs(java.util.Map<java.lang.String,java.lang.Byte> reversedExprs)
setReversedExprs
in class JoinDesc
public boolean isNoOuterJoin()
isNoOuterJoin
in class JoinDesc
public void setNoOuterJoin(boolean noOuterJoin)
setNoOuterJoin
in class JoinDesc
public JoinCondDesc[] getConds()
public void setConds(JoinCondDesc[] conds)
public java.lang.Byte[] getTagOrder()
JoinDesc
getTagOrder
in class JoinDesc
public void setTagOrder(java.lang.Byte[] tagOrder)
JoinDesc
setTagOrder
in class JoinDesc
tagOrder
- Array of tagspublic TableDesc getKeyTableDesc()
getKeyTableDesc
in class JoinDesc
public void setKeyTableDesc(TableDesc keyTableDesc)
setKeyTableDesc
in class JoinDesc
public int[][] getFilterMap()
getFilterMap
in class JoinDesc
public void setFilterMap(int[][] filterMap)
setFilterMap
in class JoinDesc
public java.util.Map<java.lang.Integer,java.lang.String> getFilterMapString()
getFilterMapString
in class JoinDesc
public java.util.Map<java.lang.Byte,java.util.List<java.lang.Integer>> getRetainList()
public void setRetainList(java.util.Map<java.lang.Byte,java.util.List<java.lang.Integer>> retainList)
public java.util.Map<java.lang.Byte,java.util.List<ExprNodeDesc>> getKeys()
public void setKeys(java.util.Map<java.lang.Byte,java.util.List<ExprNodeDesc>> keys)
keys
- the keys to setpublic int getPosBigTable()
public void setPosBigTable(int posBigTable)
posBigTable
- the position of the big table not in memorypublic TableDesc getKeyTblDesc()
public void setKeyTblDesc(TableDesc keyTblDesc)
keyTblDesc
- the keyTblDesc to setpublic java.util.List<TableDesc> getValueTblDescs()
public void setValueTblDescs(java.util.List<TableDesc> valueTblDescs)
valueTblDescs
- the valueTblDescs to setpublic BucketMapJoinContext getBucketMapjoinContext()
public void setBucketMapjoinContext(BucketMapJoinContext bucketMapjoinContext)
Copyright © 2012 The Apache Software Foundation