org.apache.pig.pen
Class LineageTrimmingVisitor

java.lang.Object
  extended by org.apache.pig.newplan.PlanVisitor
      extended by org.apache.pig.newplan.logical.relational.LogicalRelationalNodesVisitor
          extended by 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
LineageTrimmingVisitor(LogicalPlan plan, Map<LOLoad,DataBag> baseData, ExampleGenerator eg, Map<Operator,PhysicalOperator> LogToPhyMap, PhysicalPlan physPlan, PigContext pc)
           
 
Method Summary
 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(LOStore store)
           
 void visit(LOUnion u)
           
 
Methods inherited from class org.apache.pig.newplan.logical.relational.LogicalRelationalNodesVisitor
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(LOUnion u)
           throws FrontendException
Overrides:
visit in class LogicalRelationalNodesVisitor
Throws:
FrontendException


Copyright © 2007-2012 The Apache Software Foundation