org.apache.pig.pen

Class ExampleGenerator

java.lang.Object

org.apache.pig.pen.ExampleGenerator

public class ExampleGenerator
extends java.lang.Object

This class is used to generate example tuples for the ILLUSTRATE purpose

Constructor Summary

Constructors

Constructor and Description
ExampleGenerator(LogicalPlan plan, PigContext hadoopPigContext)

Method Summary

Modifier and Type	Method and Description
java.util.Map<Operator,DataBag>	getData()
java.util.Map<Operator,DataBag>	getData(java.util.Map<LOLoad,DataBag> newBaseData)
java.util.Collection<IdentityHashSet<Tuple>>	getEqClasses()
java.util.Map<Operator,DataBag>	getExamples()
LineageTracer	getLineage()
java.util.Map<Operator,PhysicalOperator>	getLogToPhyMap()
java.util.Map<LogicalRelationalOperator,java.util.Collection<IdentityHashSet<Tuple>>>	getLoToEqClassMap()
void	setMaxRecords(int max)

Methods inherited from class java.lang.Object

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

Constructor Detail

ExampleGenerator

public ExampleGenerator(LogicalPlan plan,
                        PigContext hadoopPigContext)

Method Detail

getLineage

public LineageTracer getLineage()

getLogToPhyMap

public java.util.Map<Operator,PhysicalOperator> getLogToPhyMap()

setMaxRecords

public void setMaxRecords(int max)

getExamples

public java.util.Map<Operator,DataBag> getExamples()
                                            throws java.io.IOException,
                                                   java.lang.InterruptedException

Throws:

java.io.IOException

java.lang.InterruptedException

getData

public java.util.Map<Operator,DataBag> getData()
                                        throws java.io.IOException,
                                               java.lang.InterruptedException

Throws:

java.io.IOException

java.lang.InterruptedException

getData

public java.util.Map<Operator,DataBag> getData(java.util.Map<LOLoad,DataBag> newBaseData)
                                        throws java.lang.Exception

Throws:

java.lang.Exception

getEqClasses

public java.util.Collection<IdentityHashSet<Tuple>> getEqClasses()

getLoToEqClassMap

public java.util.Map<LogicalRelationalOperator,java.util.Collection<IdentityHashSet<Tuple>>> getLoToEqClassMap()