org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.plans

Class DotMRPrinter.InnerPlan

java.lang.Object

org.apache.pig.impl.plan.OperatorPlan<DotMRPrinter.InnerOperator>

org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.plans.DotMRPrinter.InnerPlan

All Implemented Interfaces:

Serializable, Cloneable, Iterable<DotMRPrinter.InnerOperator>

Enclosing class:

DotMRPrinter

public static class DotMRPrinter.InnerPlan
extends OperatorPlan<DotMRPrinter.InnerOperator>

Helper class to represent the relationship of map, reduce and combine phases in an MR operator. Each MR operator will have an inner plan of map -> (combine)? -> (reduce)? inner operators. The inner operators contain the physical plan of the execution phase.

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
InnerPlan(PhysicalPlan mapPlan, PhysicalPlan combinePlan, PhysicalPlan reducePlan)

Method Summary

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

add, addAsLeaf, addAsRoot, 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, toString, wait, wait, wait

Methods inherited from interface java.lang.Iterable

forEach, spliterator

Constructor Detail

InnerPlan

public InnerPlan(PhysicalPlan mapPlan,
                 PhysicalPlan combinePlan,
                 PhysicalPlan reducePlan)