org.apache.hadoop.hive.ql.plan

Class SparkHashTableSinkDesc

java.lang.Object

org.apache.hadoop.hive.ql.plan.AbstractOperatorDesc

org.apache.hadoop.hive.ql.plan.JoinDesc

org.apache.hadoop.hive.ql.plan.HashTableSinkDesc

org.apache.hadoop.hive.ql.plan.SparkHashTableSinkDesc

All Implemented Interfaces:

Serializable, Cloneable, OperatorDesc

public class SparkHashTableSinkDesc
extends HashTableSinkDesc

Map Join operator Descriptor implementation.

See Also:

Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	SparkHashTableSinkDesc.SparkHashTableSinkOperatorExplainVectorization

Field Summary

Fields inherited from class org.apache.hadoop.hive.ql.plan.HashTableSinkDesc

conds, noOuterJoin, outputColumnNames, tagOrder

Fields inherited from class org.apache.hadoop.hive.ql.plan.JoinDesc

FULL_OUTER_JOIN, inMemoryDataSize, INNER_JOIN, LEFT_OUTER_JOIN, LEFT_SEMI_JOIN, memoryMonitorInfo, RIGHT_OUTER_JOIN, UNIQUE_JOIN

Fields inherited from class org.apache.hadoop.hive.ql.plan.AbstractOperatorDesc

colExprMap, memAvailable, memNeeded, opProps, opTraits, runtimeStatsTmpDir, statistics, vectorDesc, vectorMode

Constructor Summary

Constructors

Constructor and Description
SparkHashTableSinkDesc()
SparkHashTableSinkDesc(MapJoinDesc clone)

Method Summary

Modifier and Type	Method and Description
SparkHashTableSinkDesc.SparkHashTableSinkOperatorExplainVectorization	getHashTableSinkVectorization()
byte	getTag()
void	setTag(byte tag)

Methods inherited from class org.apache.hadoop.hive.ql.plan.HashTableSinkDesc

getBigKeysDirMap, getBucketMapjoinContext, getConds, getDumpFilePrefix, getExprs, getFilterMap, getFilterMapString, getFilters, getHashtableMemoryUsage, getKeys, getKeysString, getKeyTableDesc, getKeyTblDesc, getOutputColumnNames, getPosBigTable, getRetainList, getReversedExprs, getSkewKeyDefinition, getSkewKeysValuesTables, getSmallKeysDirMap, getTagOrder, getUserLevelExplainKeysString, getValueTblDescs, getValueTblFilteredDescs, isHandleSkewJoin, isNoOuterJoin, isSame, setBigKeysDirMap, setBucketMapjoinContext, setConds, setDumpFilePrefix, setExprs, setFilterMap, setFilters, setHandleSkewJoin, setHashtableMemoryUsage, setKeys, setKeyTableDesc, setKeyTblDesc, setNoOuterJoin, setOutputColumnNames, setPosBigTable, setRetainList, setReversedExprs, setSkewKeyDefinition, setSkewKeysValuesTables, setSmallKeysDirMap, setTagOrder, setValueTblDescs, setValueTblFilteredDescs

Methods inherited from class org.apache.hadoop.hive.ql.plan.JoinDesc

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

Methods inherited from class org.apache.hadoop.hive.ql.plan.AbstractOperatorDesc

fillSignature, getColumnExprMap, getMaxMemoryAvailable, getMemoryNeeded, getOpProps, getRuntimeStatsTmpDir, getStatistics, getTraits, getUserLevelStatistics, getVectorDesc, getVectorMode, setColumnExprMap, setMaxMemoryAvailable, setMemoryNeeded, setOpProps, setRuntimeStatsTmpDir, setStatistics, setTraits, setVectorDesc, setVectorMode

Methods inherited from class java.lang.Object

equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

SparkHashTableSinkDesc

public SparkHashTableSinkDesc()

SparkHashTableSinkDesc

public SparkHashTableSinkDesc(MapJoinDesc clone)

Method Detail

getTag

public byte getTag()

setTag

public void setTag(byte tag)

getHashTableSinkVectorization

public SparkHashTableSinkDesc.SparkHashTableSinkOperatorExplainVectorization getHashTableSinkVectorization()