org.apache.pig.backend.hadoop.executionengine.mapReduceLayer
Class AccumulatorOptimizer

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

public class AccumulatorOptimizer
extends MROpPlanVisitor

A visitor to optimize plans that determines if a reduce plan can run in accumulative mode.


Field Summary
 
Fields inherited from class org.apache.pig.impl.plan.PlanVisitor
mCurrentWalker, mPlan
 
Constructor Summary
AccumulatorOptimizer(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

AccumulatorOptimizer

public AccumulatorOptimizer(MROperPlan plan)
Method Detail

visitMROp

public void visitMROp(MapReduceOper mr)
               throws VisitorException
Overrides:
visitMROp in class MROpPlanVisitor
Throws:
VisitorException


Copyright © 2007-2012 The Apache Software Foundation