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

Field Summary

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

vectorColumnNameMap, vectorColumnTypeMap, vectorScratchColumnTypeMap

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

opProps, opTraits, statistics, vectorMode

Constructor Summary

Constructors

Constructor and Description
UnionWork()
UnionWork(String name)

Method Summary

Methods

Modifier and Type	Method and Description
void	addUnionOperators(Collection<UnionOperator> unions)
void	configureJobConf(org.apache.hadoop.mapred.JobConf job)
Set<Operator<?>>	getAllRootOperators()
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, getAllOperators, getDummyOps, getMapRedLocalWork, getSortCols, getTag, getVectorColumnNameMap, getVectorColumnTypeMap, getVectorScratchColumnTypeMap, isGatheringStats, setDummyOps, setGatheringStats, setMapRedLocalWork, setName, setTag, setVectorColumnNameMap, setVectorColumnTypeMap, setVectorScratchColumnTypeMap

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

clone, getOpProps, getStatistics, getTraits, getVectorMode, setOpProps, setStatistics, setTraits, 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

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