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.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	EndOfAllInputSetter.EndOfAllInputChecker

Field Summary

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

mCurrentWalker, mPlan

Constructor Summary

Constructors

Constructor and Description
EndOfAllInputSetter(MROperPlan plan)

Method Summary

Modifier and Type	Method and Description
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