org.apache.pig.backend.hadoop.executionengine.tez.plan

Class TezPlanContainer

java.lang.Object

org.apache.pig.impl.plan.OperatorPlan<TezPlanContainerNode>

org.apache.pig.backend.hadoop.executionengine.tez.plan.TezPlanContainer

All Implemented Interfaces:

Serializable, Cloneable, Iterable<TezPlanContainerNode>

public class TezPlanContainer
extends OperatorPlan<TezPlanContainerNode>

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.pig.impl.plan.OperatorPlan

OperatorPlan.IndexHelper<E>

Field Summary

Fields inherited from class org.apache.pig.impl.plan.OperatorPlan

log, mFromEdges, mKeys, mOps, mSoftFromEdges, mSoftToEdges, mToEdges

Constructor Summary

Constructors

Constructor and Description
TezPlanContainer(PigContext pigContext)

Method Summary

Methods

Modifier and Type	Method and Description
void	addPlan(TezOperPlan plan)
Map<String,org.apache.hadoop.yarn.api.records.LocalResource>	getLocalResources()
TezPlanContainerNode	getNextPlan(List<TezOperPlan> processedPlans)
static void	resetScope()
void	split(TezPlanContainerNode planNode)
String	toString()
void	updatePlan(TezOperPlan plan, boolean succ)

Methods inherited from class org.apache.pig.impl.plan.OperatorPlan

add, addAsLeaf, connect, createSoftLink, disconnect, doInsertBetween, dump, getKeys, getLeaves, getOperator, getOperatorKey, getPredecessors, getRoots, getSoftLinkPredecessors, getSoftLinkSuccessors, getSuccessors, insertBetween, isSingleLeafPlan, iterator, merge, mergeSharedPlan, pathExists, pushAfter, pushBefore, remove, removeAndReconnect, removeAndReconnectMultiSucc, removeSoftLink, replace, size, swap, trimAbove, trimBelow

Methods inherited from class java.lang.Object

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

Constructor Detail

TezPlanContainer

public TezPlanContainer(PigContext pigContext)

Method Detail

getLocalResources

public Map<String,org.apache.hadoop.yarn.api.records.LocalResource> getLocalResources()
                                                                               throws Exception

Throws:

Exception

getNextPlan

public TezPlanContainerNode getNextPlan(List<TezOperPlan> processedPlans)

addPlan

public void addPlan(TezOperPlan plan)
             throws PlanException

Throws:

PlanException

updatePlan

public void updatePlan(TezOperPlan plan,
              boolean succ)

split

public void split(TezPlanContainerNode planNode)
           throws PlanException

Throws:

PlanException

resetScope

public static void resetScope()

toString

public String toString()

Overrides:

toString in class Object