org.apache.hadoop.hive.ql.plan

Class UnionWork

java.lang.Object

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

org.apache.hadoop.hive.ql.plan.BaseWork

org.apache.hadoop.hive.ql.plan.UnionWork

All Implemented Interfaces:

Serializable, Cloneable, OperatorDesc

public class UnionWork
extends BaseWork

Simple wrapper for union all cases. All contributing work for a union all is collected here. Downstream work will connect to the union not the individual work.

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.hadoop.hive.ql.plan.BaseWork

BaseWork.BaseExplainVectorization

Field Summary

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

inputFormatSupportSet, llapMode, LOG, supportRemovedReasons, supportSetInUse, uberMode, useVectorizedInputFileFormat, vectorizationEnabled, vectorizationExamined, vectorizedRowBatchCtx, vectorizedTestingReducerBatchSize, vectorizedVertexNum

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
UnionWork()
UnionWork(String name)

Method Summary

Modifier and Type	Method and Description
void	addUnionOperators(Collection<UnionOperator> unions)
void	configureJobConf(org.apache.hadoop.mapred.JobConf job)
Set<Operator<?>>	getAllRootOperators()
Operator<? extends OperatorDesc>	getAnyRootOperator()
String	getName()
Set<UnionOperator>	getUnionOperators()
void	replaceRoots(Map<Operator<?>,Operator<?>> replacementMap)

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

addDummyOp, addSortCols, getAllLeafOperators, getAllNative, getAllOperators, getDummyOps, getInputSourceToRuntimeValuesInfo, getIsTestForcedVectorizationEnable, getIsTestVectorizationSuppressExplainExecutionMode, getLlapMode, getMapRedLocalWork, getNotVectorizedReason, getReservedMemoryMB, getSortCols, getTag, getUberMode, getUsesVectorUDFAdaptor, getVectorizationEnabled, getVectorizationExamined, getVectorizedRowBatchCtx, getVectorizedTestingReducerBatchSize, getVectorizedVertexNum, isGatheringStats, setAllNative, setDummyOps, setGatheringStats, setInputSourceToRuntimeValuesInfo, setIsTestForcedVectorizationEnable, setIsTestVectorizationSuppressExplainExecutionMode, setLlapMode, setMapRedLocalWork, setName, setNotVectorizedReason, setReservedMemoryMB, setTag, setUberMode, setUsesVectorUDFAdaptor, setVectorizationEnabled, setVectorizationExamined, setVectorizedRowBatchCtx, setVectorizedTestingReducerBatchSize, setVectorizedVertexNum

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

clone, fillSignature, getColumnExprMap, getColumnExprMapForExplain, getMaxMemoryAvailable, getMemoryNeeded, getOpProps, getRuntimeStatsTmpDir, getStatistics, getTraits, getUserLevelStatistics, getVectorDesc, getVectorMode, isSame, 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

UnionWork

public UnionWork()

UnionWork

public UnionWork(String name)

Method Detail

getName

public String getName()

Overrides:

getName in class BaseWork

replaceRoots

public void replaceRoots(Map<Operator<?>,Operator<?>> replacementMap)

Specified by:

replaceRoots in class BaseWork

getAllRootOperators

public Set<Operator<?>> getAllRootOperators()

Specified by:

getAllRootOperators in class BaseWork

getAnyRootOperator

public Operator<? extends OperatorDesc> getAnyRootOperator()

Specified by:

getAnyRootOperator in class BaseWork

addUnionOperators

public void addUnionOperators(Collection<UnionOperator> unions)

getUnionOperators

public Set<UnionOperator> getUnionOperators()

configureJobConf

public void configureJobConf(org.apache.hadoop.mapred.JobConf job)

Specified by:

configureJobConf in class BaseWork