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

java.lang.Object
  extended by org.apache.pig.impl.plan.PlanVisitor<MapReduceOper,MROperPlan>
      extended by org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.plans.MROpPlanVisitor
          extended by 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


Copyright © 2007-2012 The Apache Software Foundation