org.apache.pig.pen
Class AugmentBaseDataVisitor

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.AugmentBaseDataVisitor

public class AugmentBaseDataVisitor
extends LogicalRelationalNodesVisitor


Field Summary
 
Fields inherited from class org.apache.pig.newplan.PlanVisitor
currentWalker, DEFAULT_SCOPE, plan
 
Constructor Summary
AugmentBaseDataVisitor(OperatorPlan plan, Map<Operator,PhysicalOperator> logToPhysMap, Map<LOLoad,DataBag> baseData, Map<Operator,DataBag> derivedData)
           
 
Method Summary
 Map<LOLoad,DataBag> getNewBaseData()
           
 Map<LOLimit,Long> getOriLimitMap()
           
 void setLimit()
           
 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 lm)
           
 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, 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

AugmentBaseDataVisitor

public AugmentBaseDataVisitor(OperatorPlan plan,
                              Map<Operator,PhysicalOperator> logToPhysMap,
                              Map<LOLoad,DataBag> baseData,
                              Map<Operator,DataBag> derivedData)
                       throws FrontendException
Throws:
FrontendException
Method Detail

setLimit

public void setLimit()

getNewBaseData

public Map<LOLoad,DataBag> getNewBaseData()
                                   throws ExecException
Throws:
ExecException

getOriLimitMap

public Map<LOLimit,Long> getOriLimitMap()

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(LOForEach forEach)
           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(LOStore store)
           throws FrontendException
Overrides:
visit in class LogicalRelationalNodesVisitor
Throws:
FrontendException

visit

public void visit(LOUnion u)
           throws FrontendException
Overrides:
visit in class LogicalRelationalNodesVisitor
Throws:
FrontendException

visit

public void visit(LOLimit lm)
           throws FrontendException
Overrides:
visit in class LogicalRelationalNodesVisitor
Throws:
FrontendException


Copyright © 2007-2012 The Apache Software Foundation