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

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


Copyright © 2007-2012 The Apache Software Foundation