org.apache.pig.pen

Class LineageTrimmingVisitor

java.lang.Object

org.apache.pig.newplan.PlanVisitor

org.apache.pig.newplan.logical.relational.LogicalRelationalNodesVisitor

org.apache.pig.pen.LineageTrimmingVisitor

public class LineageTrimmingVisitor
extends LogicalRelationalNodesVisitor

Field Summary

Fields inherited from class org.apache.pig.newplan.PlanVisitor

currentWalker, DEFAULT_SCOPE

Constructor Summary

Constructors

Constructor and Description
LineageTrimmingVisitor(LogicalPlan plan, Map<LOLoad,DataBag> baseData, ExampleGenerator eg, Map<Operator,PhysicalOperator> LogToPhyMap, PhysicalPlan physPlan, PigContext pc)

Method Summary

Modifier and Type	Method and Description
void	init()
void	visit(LOCogroup cg)
void	visit(LOCross cs)
void	visit(LODistinct dt)
void	visit(LOFilter filter)
void	visit(LOForEach forEach)
void	visit(LOJoin join)
void	visit(LOLimit limOp)
void	visit(LOLoad load)
void	visit(LOSort s)
void	visit(LOSplit split)
void	visit(LOSplitOutput split)
void	visit(LOStore store)
void	visit(LOUnion u)

Methods inherited from class org.apache.pig.newplan.logical.relational.LogicalRelationalNodesVisitor

visit, visit, visit, visit, visit, visit

Methods inherited from class org.apache.pig.newplan.PlanVisitor

getPlan, popWalker, pushWalker, visit

Methods inherited from class java.lang.Object

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

Constructor Detail

LineageTrimmingVisitor

public LineageTrimmingVisitor(LogicalPlan plan,
                              Map<LOLoad,DataBag> baseData,
                              ExampleGenerator eg,
                              Map<Operator,PhysicalOperator> LogToPhyMap,
                              PhysicalPlan physPlan,
                              PigContext pc)
                       throws IOException,
                              InterruptedException

Throws:

IOException

InterruptedException

Method Detail

init

public void init()
          throws IOException,
                 InterruptedException

Throws:

IOException

InterruptedException

visit

public void visit(LOCogroup cg)
           throws FrontendException

Overrides:

visit in class LogicalRelationalNodesVisitor

Throws:

FrontendException

visit

public void visit(LOJoin join)
           throws FrontendException

Overrides:

visit in class LogicalRelationalNodesVisitor

Throws:

FrontendException

visit

public void visit(LOCross cs)
           throws FrontendException

Overrides:

visit in class LogicalRelationalNodesVisitor

Throws:

FrontendException

visit

public void visit(LODistinct dt)
           throws FrontendException

Overrides:

visit in class LogicalRelationalNodesVisitor

Throws:

FrontendException

visit

public void visit(LOFilter filter)
           throws FrontendException

Overrides:

visit in class LogicalRelationalNodesVisitor

Throws:

FrontendException

visit

public void visit(LOStore store)
           throws FrontendException

Overrides:

visit in class LogicalRelationalNodesVisitor

Throws:

FrontendException

visit

public void visit(LOForEach forEach)
           throws FrontendException

Overrides:

visit in class LogicalRelationalNodesVisitor

Throws:

FrontendException

visit

public void visit(LOLimit limOp)
           throws FrontendException

Overrides:

visit in class LogicalRelationalNodesVisitor

Throws:

FrontendException

visit

public void visit(LOLoad load)
           throws FrontendException

Overrides:

visit in class LogicalRelationalNodesVisitor

Throws:

FrontendException

visit

public void visit(LOSort s)
           throws FrontendException

Overrides:

visit in class LogicalRelationalNodesVisitor

Throws:

FrontendException

visit

public void visit(LOSplit split)
           throws FrontendException

Overrides:

visit in class LogicalRelationalNodesVisitor

Throws:

FrontendException

visit

public void visit(LOSplitOutput split)
           throws FrontendException

Overrides:

visit in class LogicalRelationalNodesVisitor

Throws:

FrontendException

visit

public void visit(LOUnion u)
           throws FrontendException

Overrides:

visit in class LogicalRelationalNodesVisitor

Throws:

FrontendException