org.apache.pig.pen

Class Illustrator

java.lang.Object

org.apache.pig.pen.Illustrator

public class Illustrator
extends Object

Class used by physical operators to generate example tuples for the ILLUSTRATE purpose

Constructor Summary

Constructors

Constructor and Description
Illustrator(LineageTracer lineage, LinkedList<IdentityHashSet<Tuple>> equivalenceClasses, IllustratorAttacher attacher, PigContext hadoopPigContext)
Illustrator(LineageTracer lineage, LinkedList<IdentityHashSet<Tuple>> equivalenceClasses, int maxRecords, IllustratorAttacher attacher, LogicalSchema schema, PigContext hadoopPigContext)

Method Summary

Modifier and Type	Method and Description
void	addData(Tuple t)
void	addInputs(IdentityHashSet<Tuple> inputs)
boolean	ceilingCheck()
DataBag	getData()
boolean	getEqClassesShared()
LinkedList<IdentityHashSet<Tuple>>	getEquivalenceClasses()
IdentityHashSet<Tuple>	getInputs()
LineageTracer	getLineage()
long	getOriginalLimit()
LogicalSchema	getSchema()
ArrayList<Boolean[]>	getSubExpResults()
void	setEqClassesShared()
void	setEquivalenceClasses(LinkedList<IdentityHashSet<Tuple>> eqClasses, PhysicalOperator po)
void	setOriginalLimit(long oriLimit)
void	setSubExpResult(boolean result)

Methods inherited from class java.lang.Object

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

Constructor Detail

Illustrator

public Illustrator(LineageTracer lineage,
                   LinkedList<IdentityHashSet<Tuple>> equivalenceClasses,
                   IllustratorAttacher attacher,
                   PigContext hadoopPigContext)

Illustrator

public Illustrator(LineageTracer lineage,
                   LinkedList<IdentityHashSet<Tuple>> equivalenceClasses,
                   int maxRecords,
                   IllustratorAttacher attacher,
                   LogicalSchema schema,
                   PigContext hadoopPigContext)

Method Detail

getSubExpResults

public ArrayList<Boolean[]> getSubExpResults()

getLineage

public LineageTracer getLineage()

getEquivalenceClasses

public LinkedList<IdentityHashSet<Tuple>> getEquivalenceClasses()

setSubExpResult

public void setSubExpResult(boolean result)

setEquivalenceClasses

public void setEquivalenceClasses(LinkedList<IdentityHashSet<Tuple>> eqClasses,
                                  PhysicalOperator po)

ceilingCheck

public boolean ceilingCheck()

getInputs

public IdentityHashSet<Tuple> getInputs()

addInputs

public void addInputs(IdentityHashSet<Tuple> inputs)

addData

public void addData(Tuple t)

getData

public DataBag getData()

getOriginalLimit

public long getOriginalLimit()

setOriginalLimit

public void setOriginalLimit(long oriLimit)

setEqClassesShared

public void setEqClassesShared()

getEqClassesShared

public boolean getEqClassesShared()

getSchema

public LogicalSchema getSchema()