org.apache.pig.pen

Class LocalMapReduceSimulator

java.lang.Object

org.apache.pig.pen.LocalMapReduceSimulator

public class LocalMapReduceSimulator
extends java.lang.Object

Main class that launches pig for Map Reduce

Constructor Summary

Constructors

Constructor and Description
LocalMapReduceSimulator()

Method Summary

Modifier and Type	Method and Description
java.util.Map<PhysicalOperator,PhysicalOperator>	getPhyToMRMap()
void	launchPig(PhysicalPlan php, java.util.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,
                      java.util.Map<LOLoad,DataBag> baseData,
                      LineageTracer lineage,
                      IllustratorAttacher attacher,
                      ExampleGenerator eg,
                      PigContext pc)
               throws PigException,
                      java.io.IOException,
                      java.lang.InterruptedException

Throws:

PigException

java.io.IOException

java.lang.InterruptedException

getPhyToMRMap

public java.util.Map<PhysicalOperator,PhysicalOperator> getPhyToMRMap()