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

Class CombinerOptimizer

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

public class CombinerOptimizer
extends MROpPlanVisitor

Optimize map reduce plans to use the combiner where possible.

Field Summary

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

mCurrentWalker, mPlan

Constructor Summary

Constructors

Constructor and Description
CombinerOptimizer(MROperPlan plan, boolean doMapAgg)
CombinerOptimizer(MROperPlan plan, boolean doMapAgg, CompilationMessageCollector messageCollector)

Method Summary

Modifier and Type	Method and Description
CompilationMessageCollector	getMessageCollector()
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

CombinerOptimizer

public CombinerOptimizer(MROperPlan plan,
                         boolean doMapAgg)

CombinerOptimizer

public CombinerOptimizer(MROperPlan plan,
                         boolean doMapAgg,
                         CompilationMessageCollector messageCollector)

Method Detail

getMessageCollector

public CompilationMessageCollector getMessageCollector()

visitMROp

public void visitMROp(MapReduceOper mr)
               throws VisitorException

Overrides:

visitMROp in class MROpPlanVisitor

Throws:

VisitorException