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

DotMRPrinter.InnerPlan(PhysicalPlan mapPlan, PhysicalPlan combinePlan, PhysicalPlan reducePlan)

Method Summary

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, toString, wait, wait, wait

Constructor Detail

DotMRPrinter.InnerPlan

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