org.apache.pig.pen
Class LocalMapReduceSimulator

java.lang.Object
  org.apache.pig.pen.LocalMapReduceSimulator

public class LocalMapReduceSimulator
extends Object

Main class that launches pig for Map Reduce

Constructor Summary

LocalMapReduceSimulator()

Method Summary

Map<PhysicalOperator,PhysicalOperator>	getPhyToMRMap()
void	launchPig(PhysicalPlan php, Map<LOLoad,DataBag> baseData, LineageTracer lineage, IllustratorAttacher attacher, ExampleGenerator eg, PigContext pc)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

LocalMapReduceSimulator

public LocalMapReduceSimulator()

Method Detail

launchPig

public void launchPig(PhysicalPlan php,
                      Map<LOLoad,DataBag> baseData,
                      LineageTracer lineage,
                      IllustratorAttacher attacher,
                      ExampleGenerator eg,
                      PigContext pc)
               throws PigException,
                      IOException,
                      InterruptedException

Throws:

PigException

IOException

InterruptedException

getPhyToMRMap

public Map<PhysicalOperator,PhysicalOperator> getPhyToMRMap()