org.apache.pig.pen
Class DerivedDataVisitor

java.lang.Object
  org.apache.pig.impl.plan.PlanVisitor<LogicalOperator,LogicalPlan>
      org.apache.pig.impl.logicalLayer.LOVisitor
          org.apache.pig.pen.DerivedDataVisitor

public class DerivedDataVisitor
extends LOVisitor

Field Summary

Fields inherited from class org.apache.pig.impl.plan.PlanVisitor

mCurrentWalker, mPlan

Constructor Summary

DerivedDataVisitor(LogicalOperator op, PigContext pc, Map<LOLoad,DataBag> baseData, Map<LogicalOperator,PhysicalOperator> logToPhyMap, PhysicalPlan physPlan)

DerivedDataVisitor(LogicalPlan plan, PigContext pc, Map<LOLoad,DataBag> baseData, Map<LogicalOperator,PhysicalOperator> logToPhyMap, PhysicalPlan physPlan)

Method Summary

DataBag	evaluateIsolatedOperator(LOCogroup op)
DataBag	evaluateIsolatedOperator(LOCogroup op, List<DataBag> inputBags)
void	setOperatorToEvaluate(LogicalOperator op)
protected void	visit(LOCogroup cg)
protected void	visit(LOCross cs)
protected void	visit(LODistinct dt)
protected void	visit(LOFilter filter)
protected void	visit(LOForEach forEach)
protected void	visit(LOLimit l)
protected void	visit(LOLoad load)
protected void	visit(LOSort sort)
protected void	visit(LOSplit split)
protected void	visit(LOStore store)
protected void	visit(LOUnion u)

Methods inherited from class org.apache.pig.impl.logicalLayer.LOVisitor

visit, visit, visit, visit, visit, visit, visit, visit, visit, visit, visit, visit, visit, visit, visit, visit, visit, visit, visit, visit, visit, visit, visit, visit, visit, visit, visit, visit, visit, visit, visit, visit

Methods inherited from class org.apache.pig.impl.plan.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

DerivedDataVisitor

public DerivedDataVisitor(LogicalPlan plan,
                          PigContext pc,
                          Map<LOLoad,DataBag> baseData,
                          Map<LogicalOperator,PhysicalOperator> logToPhyMap,
                          PhysicalPlan physPlan)

DerivedDataVisitor

public DerivedDataVisitor(LogicalOperator op,
                          PigContext pc,
                          Map<LOLoad,DataBag> baseData,
                          Map<LogicalOperator,PhysicalOperator> logToPhyMap,
                          PhysicalPlan physPlan)

Method Detail

setOperatorToEvaluate

public void setOperatorToEvaluate(LogicalOperator op)

visit

protected void visit(LOCogroup cg)
              throws VisitorException

Overrides:

visit in class LOVisitor

Parameters:

cg - the logical cogroup operator that has to be visited

Throws:

VisitorException

visit

protected void visit(LOCross cs)
              throws VisitorException

Overrides:

visit in class LOVisitor

Throws:

VisitorException

visit

protected void visit(LODistinct dt)
              throws VisitorException

Overrides:

visit in class LOVisitor

Throws:

VisitorException

visit

protected void visit(LOFilter filter)
              throws VisitorException

Overrides:

visit in class LOVisitor

Parameters:

filter - the logical filter operator that has to be visited

Throws:

VisitorException

visit

protected void visit(LOForEach forEach)
              throws VisitorException

Overrides:

visit in class LOVisitor

Parameters:

forEach - the logical foreach operator that has to be visited

Throws:

VisitorException

visit

protected void visit(LOLoad load)
              throws VisitorException

Overrides:

visit in class LOVisitor

Throws:

VisitorException

visit

protected void visit(LOSplit split)
              throws VisitorException

Overrides:

visit in class LOVisitor

Parameters:

split - the logical split operator that has to be visited

Throws:

VisitorException

visit

protected void visit(LOStore store)
              throws VisitorException

Overrides:

visit in class LOVisitor

Throws:

VisitorException

visit

protected void visit(LOUnion u)
              throws VisitorException

Overrides:

visit in class LOVisitor

Throws:

VisitorException

visit

protected void visit(LOLimit l)
              throws VisitorException

Overrides:

visit in class LOVisitor

Throws:

VisitorException

visit

protected void visit(LOSort sort)
              throws VisitorException

Overrides:

visit in class LOVisitor

Parameters:

sort - the logical sort operator that has to be visited

Throws:

VisitorException

evaluateIsolatedOperator

public DataBag evaluateIsolatedOperator(LOCogroup op,
                                        List<DataBag> inputBags)

evaluateIsolatedOperator

public DataBag evaluateIsolatedOperator(LOCogroup op)