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

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

public class POPackageAnnotator
extends MROpPlanVisitor

This visitor visits the MRPlan and does the following for each MROper - visits the POPackage in the reduce plan and finds the corresponding POLocalRearrange(s) (either in the map plan of the same oper OR reduce plan of predecessor MROper). It then annotates the POPackage with information about which columns in the "value" are present in the "key" and will need to stitched in to the "value"

Field Summary

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

mCurrentWalker, mPlan

Constructor Summary

POPackageAnnotator(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

POPackageAnnotator

public POPackageAnnotator(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