public class HashTableSinkDesc extends JoinDesc implements Serializable
Modifier and Type | Field and Description |
---|---|
protected JoinCondDesc[] |
conds |
protected boolean |
noOuterJoin |
protected List<String> |
outputColumnNames |
protected Byte[] |
tagOrder |
FULL_OUTER_JOIN, INNER_JOIN, LEFT_OUTER_JOIN, LEFT_SEMI_JOIN, RIGHT_OUTER_JOIN, UNIQUE_JOIN
memNeeded, opProps, opTraits, statistics, vectorMode
Constructor and Description |
---|
HashTableSinkDesc() |
HashTableSinkDesc(MapJoinDesc clone) |
clone, cloneQBJoinTreeProps, convertToArray, getAliasToOpInfo, getBaseSrc, getCondsList, getFiltersStringMap, getHandleSkewJoin, getId, getJoinKeys, getLeftAlias, getLeftAliases, getMapAliases, getNoOuterJoin, getNullSafes, getNullSafeString, getRightAliases, getStreamAliases, getTagLength, getUserLevelExplainOutputColumnNames, isFixedAsSorted, isLeftInputJoin, isMapSideJoin, resetOrder, setAliasToOpInfo, setBaseSrc, setFixedAsSorted, setLeftAlias, setNullSafes, setQBJoinTreeProps, setQBJoinTreeProps, setRightAliases, toCompactString
getMemoryNeeded, getOpProps, getStatistics, getTraits, getUserLevelStatistics, getVectorMode, setMemoryNeeded, setOpProps, setStatistics, setTraits, setVectorMode
protected boolean noOuterJoin
protected JoinCondDesc[] conds
protected Byte[] tagOrder
public HashTableSinkDesc()
public HashTableSinkDesc(MapJoinDesc clone)
public float getHashtableMemoryUsage()
public void setHashtableMemoryUsage(float hashtableMemoryUsage)
public String getDumpFilePrefix()
public void setDumpFilePrefix(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 Map<Byte,org.apache.hadoop.fs.Path> getBigKeysDirMap()
getBigKeysDirMap
in class JoinDesc
public void setBigKeysDirMap(Map<Byte,org.apache.hadoop.fs.Path> bigKeysDirMap)
JoinDesc
setBigKeysDirMap
in class JoinDesc
public Map<Byte,Map<Byte,org.apache.hadoop.fs.Path>> getSmallKeysDirMap()
getSmallKeysDirMap
in class JoinDesc
public void setSmallKeysDirMap(Map<Byte,Map<Byte,org.apache.hadoop.fs.Path>> smallKeysDirMap)
JoinDesc
setSmallKeysDirMap
in class JoinDesc
public Map<Byte,TableDesc> getSkewKeysValuesTables()
getSkewKeysValuesTables
in class JoinDesc
public void setSkewKeysValuesTables(Map<Byte,TableDesc> skewKeysValuesTables)
setSkewKeysValuesTables
in class JoinDesc
skewKeysValuesTables
- set the table desc for storing skew keys and their corresponding
value;public void setExprs(Map<Byte,List<ExprNodeDesc>> exprs)
public Map<Byte,List<ExprNodeDesc>> getFilters()
getFilters
in class JoinDesc
public void setValueTblFilteredDescs(List<TableDesc> valueTblFilteredDescs)
public void setFilters(Map<Byte,List<ExprNodeDesc>> filters)
setFilters
in class JoinDesc
public List<String> getOutputColumnNames()
getOutputColumnNames
in class JoinDesc
public void setOutputColumnNames(List<String> outputColumnNames)
setOutputColumnNames
in class JoinDesc
public Map<String,Byte> getReversedExprs()
getReversedExprs
in class JoinDesc
public void setReversedExprs(Map<String,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 Byte[] getTagOrder()
JoinDesc
getTagOrder
in class JoinDesc
public void setTagOrder(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 Map<Integer,String> getFilterMapString()
getFilterMapString
in class JoinDesc
public Map<Byte,String> getKeysString()
getKeysString
in class JoinDesc
public Map<Byte,String> getUserLevelExplainKeysString()
getUserLevelExplainKeysString
in class JoinDesc
public Map<Byte,List<ExprNodeDesc>> getKeys()
public void setKeys(Map<Byte,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 void setValueTblDescs(List<TableDesc> valueTblDescs)
valueTblDescs
- the valueTblDescs to setpublic BucketMapJoinContext getBucketMapjoinContext()
public void setBucketMapjoinContext(BucketMapJoinContext bucketMapjoinContext)
Copyright © 2016 The Apache Software Foundation. All rights reserved.