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

Constructor Summary

UnionWork()

UnionWork(String name)

Method Summary

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, getAllOperators, getDummyOps, isGatheringStats, setDummyOps, setGatheringStats, setName

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

clone, getOpTraits, getStatistics, setOpTraits, setStatistics, setVectorMode

Methods inherited from class java.lang.Object

equals, 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