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

java.lang.Object
  org.apache.pig.impl.plan.PlanVisitor<MapReduceOper,MROperPlan>
      org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.plans.MROpPlanVisitor
          org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.plans.EndOfAllInputSetter

public class EndOfAllInputSetter
extends MROpPlanVisitor

This visitor visits the MRPlan and does the following for each MROper: If the map plan or the reduce plan of the MROper has an end of all input flag present in it, this marks in the MROper whether the map has an end of all input flag set or if the reduce has an end of all input flag set.

Field Summary

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

mCurrentWalker, mPlan

Constructor Summary

EndOfAllInputSetter(MROperPlan plan)

Method Summary

void	visitMROp(MapReduceOper mr)

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

getPlan, popWalker, pushWalker, visit

Methods inherited from class java.lang.Object

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

Constructor Detail

EndOfAllInputSetter

public EndOfAllInputSetter(MROperPlan plan)

Parameters:

plan - MR plan to visit

Method Detail

visitMROp

public void visitMROp(MapReduceOper mr)
               throws VisitorException

Overrides:

visitMROp in class MROpPlanVisitor

Throws:

VisitorException