org.apache.pig.newplan.logical.optimizer

Class SchemaResetter

java.lang.Object

org.apache.pig.newplan.PlanVisitor

org.apache.pig.newplan.logical.relational.LogicalRelationalNodesVisitor

org.apache.pig.newplan.logical.optimizer.SchemaResetter

public class SchemaResetter
extends LogicalRelationalNodesVisitor

Field Summary

Fields inherited from class org.apache.pig.newplan.PlanVisitor

currentWalker, DEFAULT_SCOPE, plan

Constructor Summary

Constructors

Constructor and Description
SchemaResetter(OperatorPlan plan)
SchemaResetter(OperatorPlan plan, boolean skipDuplicateUidCheck)

Method Summary

Modifier and Type	Method and Description
void	validate(LogicalSchema schema) Check if schema is valid (ready to be part of a final logical plan)
void	visit(LOCogroup loCogroup)
void	visit(LOCross loCross)
void	visit(LOCube loCube)
void	visit(LODistinct loDistinct)
void	visit(LOFilter filter)
void	visit(LOForEach foreach)
void	visit(LOGenerate gen)
void	visit(LOInnerLoad load)
void	visit(LOJoin join)
void	visit(LOLimit loLimit)
void	visit(LOLoad load)
void	visit(LORank loRank)
void	visit(LOSort loSort)
void	visit(LOSplit loSplit)
void	visit(LOSplitOutput loSplitOutput)
void	visit(LOStore store)
void	visit(LOStream loStream)
void	visit(LOUnion loUnion)

Methods inherited from class org.apache.pig.newplan.logical.relational.LogicalRelationalNodesVisitor

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

SchemaResetter

public SchemaResetter(OperatorPlan plan)
               throws FrontendException

Throws:

FrontendException

SchemaResetter

public SchemaResetter(OperatorPlan plan,
                      boolean skipDuplicateUidCheck)
               throws FrontendException

Throws:

FrontendException

Method Detail

visit

public void visit(LOLoad load)
           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(LOJoin join)
           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(LOGenerate gen)
           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(LOCube loCube)
           throws FrontendException

Overrides:

visit in class LogicalRelationalNodesVisitor

Throws:

FrontendException

visit

public void visit(LOCogroup loCogroup)
           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

visit

public void visit(LOUnion loUnion)
           throws FrontendException

Overrides:

visit in class LogicalRelationalNodesVisitor

Throws:

FrontendException

visit

public void visit(LOSort loSort)
           throws FrontendException

Overrides:

visit in class LogicalRelationalNodesVisitor

Throws:

FrontendException

visit

public void visit(LORank loRank)
           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(LOCross loCross)
           throws FrontendException

Overrides:

visit in class LogicalRelationalNodesVisitor

Throws:

FrontendException

visit

public void visit(LOStream loStream)
           throws FrontendException

Overrides:

visit in class LogicalRelationalNodesVisitor

Throws:

FrontendException

validate

public void validate(LogicalSchema schema)
              throws PlanValidationException

Check if schema is valid (ready to be part of a final logical plan)

Parameters:

schema -

Throws:

PlanValidationException - if the if any field in schema has uid -1 or (skipDuplicateUidCheck is true and there are duplicate uids in schema)