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

Constructors

Constructor and Description
MRIntermediateDataVisitor(MROperPlan plan)

Method Summary

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