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

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


Copyright © 2007-2012 The Apache Software Foundation