org.apache.pig.newplan.logical.relational
Class LogToPhyTranslationVisitor
java.lang.Object
org.apache.pig.newplan.PlanVisitor
org.apache.pig.newplan.logical.relational.LogicalRelationalNodesVisitor
org.apache.pig.newplan.logical.relational.LogToPhyTranslationVisitor
public class LogToPhyTranslationVisitor
- extends LogicalRelationalNodesVisitor
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
logToPhyMap
protected Map<Operator,PhysicalOperator> logToPhyMap
currentPlans
protected Stack<PhysicalPlan> currentPlans
currentPlan
protected PhysicalPlan currentPlan
nodeGen
protected NodeIdGenerator nodeGen
pc
protected PigContext pc
LogToPhyTranslationVisitor
public LogToPhyTranslationVisitor(OperatorPlan plan)
throws FrontendException
- Throws:
FrontendException
setPigContext
public void setPigContext(PigContext pc)
getLogToPhyMap
public Map<Operator,PhysicalOperator> getLogToPhyMap()
getPhysicalPlan
public PhysicalPlan getPhysicalPlan()
visit
public void visit(LOLoad loLoad)
throws FrontendException
- Overrides:
visit
in class LogicalRelationalNodesVisitor
- Throws:
FrontendException
visit
public void visit(LONative loNative)
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(LOSort sort)
throws FrontendException
- Overrides:
visit
in class LogicalRelationalNodesVisitor
- Throws:
FrontendException
visit
public void visit(LOCross cross)
throws FrontendException
- Overrides:
visit
in class LogicalRelationalNodesVisitor
- Throws:
FrontendException
visit
public void visit(LOStream stream)
throws FrontendException
- Overrides:
visit
in class LogicalRelationalNodesVisitor
- Throws:
FrontendException
visit
public void visit(LOInnerLoad load)
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(LOStore loStore)
throws FrontendException
- Overrides:
visit
in class LogicalRelationalNodesVisitor
- Throws:
FrontendException
visit
public void visit(LOCogroup cg)
throws FrontendException
- Overrides:
visit
in class LogicalRelationalNodesVisitor
- Throws:
FrontendException
visit
public void visit(LOJoin loj)
throws FrontendException
- Overrides:
visit
in class LogicalRelationalNodesVisitor
- Throws:
FrontendException
visit
public void visit(LOUnion loUnion)
throws FrontendException
- Overrides:
visit
in class LogicalRelationalNodesVisitor
- Throws:
FrontendException
visit
public void visit(LODistinct loDistinct)
throws FrontendException
- Overrides:
visit
in class LogicalRelationalNodesVisitor
- Throws:
FrontendException
visit
public void visit(LOLimit loLimit)
throws FrontendException
- Overrides:
visit
in class LogicalRelationalNodesVisitor
- Throws:
FrontendException
visit
public void visit(LOSplit loSplit)
throws FrontendException
- Overrides:
visit
in class LogicalRelationalNodesVisitor
- Throws:
FrontendException
visit
public void visit(LOSplitOutput loSplitOutput)
throws FrontendException
- Overrides:
visit
in class LogicalRelationalNodesVisitor
- Throws:
FrontendException
updateWithEmptyBagCheck
public static void updateWithEmptyBagCheck(PhysicalPlan fePlan,
Operator joinInput)
throws FrontendException
- updates plan with check for empty bag and if bag is empty to flatten a bag
with as many null's as dictated by the schema
- Parameters:
fePlan
- the plan to updatejoinInput
- the relation for which the corresponding bag is being checked
- Throws:
FrontendException
Copyright © ${year} The Apache Software Foundation