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, inMemoryDataSize, INNER_JOIN, LEFT_OUTER_JOIN, LEFT_SEMI_JOIN, memoryMonitorInfo, RIGHT_OUTER_JOIN, UNIQUE_JOIN
colExprMap, memAvailable, memNeeded, opProps, opTraits, runtimeStatsTmpDir, statistics, vectorDesc, vectorMode
Constructor and Description |
---|
HashTableSinkDesc() |
HashTableSinkDesc(MapJoinDesc clone) |
clone, cloneQBJoinTreeProps, convertToArray, getAliasToOpInfo, getBaseSrc, getColumnExprMapForExplain, getCondsList, getFiltersStringMap, getHandleSkewJoin, getId, getInMemoryDataSize, getJoinKeys, getLeftAlias, getLeftAliases, getMapAliases, getMemoryMonitorInfo, getNoOuterJoin, getNullSafes, getNullSafeString, getResidualFilterExprs, getResidualFilterExprsString, getRightAliases, getStreamAliases, getTagLength, getUserLevelExplainOutputColumnNames, isFixedAsSorted, isLeftInputJoin, isMapSideJoin, resetOrder, setAliasToOpInfo, setBaseSrc, setFixedAsSorted, setInMemoryDataSize, setLeftAlias, setMemoryMonitorInfo, setNullSafes, setQBJoinTreeProps, setQBJoinTreeProps, setResidualFilterExprs, setRightAliases, toCompactString
fillSignature, getColumnExprMap, getMaxMemoryAvailable, getMemoryNeeded, getOpProps, getRuntimeStatsTmpDir, getStatistics, getTraits, getUserLevelStatistics, getVectorDesc, getVectorMode, setColumnExprMap, setMaxMemoryAvailable, setMemoryNeeded, setOpProps, setRuntimeStatsTmpDir, setStatistics, setTraits, setVectorDesc, 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<String,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)
public boolean isSame(OperatorDesc other)
AbstractOperatorDesc
Object.equals(Object)
. Intended to be
overridden by sub classes.isSame
in interface OperatorDesc
isSame
in class JoinDesc
Copyright © 2022 The Apache Software Foundation. All rights reserved.