org.apache.pig.backend.hadoop.executionengine.tez.plan.optimizer

Class CombinerOptimizer

java.lang.Object

org.apache.pig.impl.plan.PlanVisitor<TezOperator,TezOperPlan>

org.apache.pig.backend.hadoop.executionengine.tez.plan.TezOpPlanVisitor

org.apache.pig.backend.hadoop.executionengine.tez.plan.optimizer.CombinerOptimizer

public class CombinerOptimizer
extends TezOpPlanVisitor

Optimize tez 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(TezOperPlan plan, boolean doMapAgg)
CombinerOptimizer(TezOperPlan plan, boolean doMapAgg, CompilationMessageCollector messageCollector)

Method Summary

Modifier and Type	Method and Description
CompilationMessageCollector	getMessageCollector()
void	visitTezOp(TezOperator to)

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(TezOperPlan plan,
                         boolean doMapAgg)

CombinerOptimizer

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

Method Detail

getMessageCollector

public CompilationMessageCollector getMessageCollector()

visitTezOp

public void visitTezOp(TezOperator to)
                throws VisitorException

Overrides:

visitTezOp in class TezOpPlanVisitor

Throws:

VisitorException