org.apache.pig.pen
Class AugmentBaseDataVisitor

java.lang.Object
  org.apache.pig.newplan.PlanVisitor
      org.apache.pig.newplan.logical.relational.LogicalRelationalNodesVisitor
          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

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