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

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.MRIntermediateDataVisitor

public class MRIntermediateDataVisitor
extends MROpPlanVisitor

An MROpPlanVisitor that gathers the paths for all intermediate data from a MROperPlan

Field Summary

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

mCurrentWalker, mPlan

Constructor Summary

MRIntermediateDataVisitor(MROperPlan plan)

Method Summary

Set<String>	getIntermediate() Get all paths for intermediate data.
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

MRIntermediateDataVisitor

public MRIntermediateDataVisitor(MROperPlan plan)

Method Detail

getIntermediate

public Set<String> getIntermediate()

Get all paths for intermediate data. visit() must be called before this.

Returns:

All intermediate data ElementDescriptors

visitMROp

public void visitMROp(MapReduceOper mr)
               throws VisitorException

Overrides:

visitMROp in class MROpPlanVisitor

Throws:

VisitorException