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

Constructors

Constructor and Description
LocalMapReduceSimulator()

Method Summary

Methods

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