Uses of Interface
org.apache.pig.newplan.OperatorPlan

Packages that use OperatorPlan

Package	Description
org.apache.pig.backend.hadoop.executionengine.physicalLayer.plans
org.apache.pig.newplan
org.apache.pig.newplan.logical.expression
org.apache.pig.newplan.logical.optimizer
org.apache.pig.newplan.logical.relational
org.apache.pig.newplan.logical.rules
org.apache.pig.newplan.logical.visitor
org.apache.pig.newplan.optimizer
org.apache.pig.pen
org.apache.pig.pen.util
org.apache.pig.tools.pigstats
org.apache.pig.validator

Uses of OperatorPlan in org.apache.pig.backend.hadoop.executionengine.physicalLayer.plans

Classes in org.apache.pig.backend.hadoop.executionengine.physicalLayer.plans that implement OperatorPlan

Modifier and Type	Class and Description
class	PatternPlan Used for finding/representing a pattern in the plan This class represents the pattern Finds only a single matching pattern This is finding a sub-graph( represented by pattern) in the graph(plan)

Constructors in org.apache.pig.backend.hadoop.executionengine.physicalLayer.plans with parameters of type OperatorPlan

Constructor and Description
PatternNode(OperatorPlan p)

Uses of OperatorPlan in org.apache.pig.newplan

Classes in org.apache.pig.newplan that implement OperatorPlan

Modifier and Type	Class and Description
class	BaseOperatorPlan
class	OperatorSubPlan Class to represent a view of a plan.

Fields in org.apache.pig.newplan declared as OperatorPlan

Modifier and Type	Field and Description
protected OperatorPlan	PlanWalker.plan
protected OperatorPlan	PlanVisitor.plan
protected OperatorPlan	Operator.plan

Methods in org.apache.pig.newplan that return OperatorPlan

Modifier and Type	Method and Description
OperatorPlan	OperatorSubPlan.getBasePlan()
OperatorPlan	PlanWalker.getPlan()
OperatorPlan	PlanVisitor.getPlan()
OperatorPlan	Operator.getPlan() Get the plan associated with this operator.

Methods in org.apache.pig.newplan with parameters of type OperatorPlan

Modifier and Type	Method and Description
boolean	OperatorSubPlan.isEqual(OperatorPlan other)
boolean	OperatorPlan.isEqual(OperatorPlan other) This is like a shallow comparison.
boolean	BaseOperatorPlan.isEqual(OperatorPlan other)
protected static boolean	BaseOperatorPlan.isEqual(OperatorPlan p1, OperatorPlan p2)
void	PlanWalker.setPlan(OperatorPlan plan) Set the plan for this walker to operate on.
void	Operator.setPlan(OperatorPlan p)
PlanWalker	ReverseDependencyOrderWalkerWOSeenChk.spawnChildWalker(OperatorPlan plan)
PlanWalker	ReverseDependencyOrderWalker.spawnChildWalker(OperatorPlan plan)
abstract PlanWalker	PlanWalker.spawnChildWalker(OperatorPlan plan) Return a new instance of this same type of walker for a subplan.
PlanWalker	DepthFirstWalker.spawnChildWalker(OperatorPlan plan)
PlanWalker	DependencyOrderWalker.spawnChildWalker(OperatorPlan plan)

Constructors in org.apache.pig.newplan with parameters of type OperatorPlan

Constructor and Description
DependencyOrderWalker(OperatorPlan plan)
DepthFirstWalker(OperatorPlan plan)
Operator(String n, OperatorPlan p)
OperatorSubPlan(OperatorPlan base)
PlanVisitor(OperatorPlan plan, PlanWalker walker)
PlanWalker(OperatorPlan plan)
ReverseDependencyOrderWalker(OperatorPlan plan)
ReverseDependencyOrderWalkerWOSeenChk(OperatorPlan plan)
SubtreeDependencyOrderWalker(OperatorPlan plan)
SubtreeDependencyOrderWalker(OperatorPlan plan, Operator startNode)

Uses of OperatorPlan in org.apache.pig.newplan.logical.expression

Classes in org.apache.pig.newplan.logical.expression that implement OperatorPlan

Modifier and Type	Class and Description
class	LogicalExpressionPlan A plan containing LogicalExpressionOperators.

Methods in org.apache.pig.newplan.logical.expression with parameters of type OperatorPlan

Modifier and Type	Method and Description
boolean	LogicalExpressionPlan.isEqual(OperatorPlan other)

Constructors in org.apache.pig.newplan.logical.expression with parameters of type OperatorPlan

Constructor and Description
AddExpression(OperatorPlan plan, LogicalExpression lhs, LogicalExpression rhs) Will add this operator to the plan and connect it to the left and right hand side operators.
AllSameExpressionVisitor(OperatorPlan plan, PlanWalker walker)
AndExpression(OperatorPlan plan, LogicalExpression lhs, LogicalExpression rhs) Will add this operator to the plan and connect it to the left and right hand side operators.
BinaryExpression(String name, OperatorPlan plan, LogicalExpression lhs, LogicalExpression rhs) Will add this operator to the plan and connect it to the left and right hand side operators.
BinCondExpression(OperatorPlan plan, LogicalExpression condition, LogicalExpression lhs, LogicalExpression rhs) Will add this operator to the plan and connect it to the left and right hand side operators and the condition operator
CastExpression(OperatorPlan plan, LogicalExpression exp, LogicalSchema.LogicalFieldSchema fs)
ColumnExpression(String name, OperatorPlan plan)
ConstantExpression(OperatorPlan plan, Object val) Adds expression to the plan
DereferenceExpression(OperatorPlan plan)
DereferenceExpression(OperatorPlan plan, int colNum)
DereferenceExpression(OperatorPlan plan, List<Integer> columnNums)
DivideExpression(OperatorPlan plan, LogicalExpression lhs, LogicalExpression rhs) Will add this operator to the plan and connect it to the left and right hand side operators.
EqualExpression(OperatorPlan plan, LogicalExpression lhs, LogicalExpression rhs) Will add this operator to the plan and connect it to the left and right hand side operators.
ExpToPhyTranslationVisitor(OperatorPlan plan, LogicalRelationalOperator op, PhysicalPlan phyPlan, Map<Operator,PhysicalOperator> map)
ExpToPhyTranslationVisitor(OperatorPlan plan, PlanWalker walker, LogicalRelationalOperator op, PhysicalPlan phyPlan, Map<Operator,PhysicalOperator> map)
GreaterThanEqualExpression(OperatorPlan plan, LogicalExpression lhs, LogicalExpression rhs) Will add this operator to the plan and connect it to the left and right hand side operators.
GreaterThanExpression(OperatorPlan plan, LogicalExpression lhs, LogicalExpression rhs) Will add this operator to the plan and connect it to the left and right hand side operators.
IsNullExpression(OperatorPlan plan, LogicalExpression exp)
LessThanEqualExpression(OperatorPlan plan, LogicalExpression lhs, LogicalExpression rhs) Will add this operator to the plan and connect it to the left and right hand side operators.
LessThanExpression(OperatorPlan plan, LogicalExpression lhs, LogicalExpression rhs) Will add this operator to the plan and connect it to the left and right hand side operators.
LogicalExpression(String name, OperatorPlan plan)
LogicalExpressionVisitor(OperatorPlan p, PlanWalker walker)
MapLookupExpression(OperatorPlan plan, String mapKey)
ModExpression(OperatorPlan plan, LogicalExpression lhs, LogicalExpression rhs) Will add this operator to the plan and connect it to the left and right hand side operators.
MultiplyExpression(OperatorPlan plan, LogicalExpression lhs, LogicalExpression rhs) Will add this operator to the plan and connect it to the left and right hand side operators.
NegativeExpression(OperatorPlan plan, LogicalExpression exp)
NotEqualExpression(OperatorPlan plan, LogicalExpression lhs, LogicalExpression rhs) Will add this operator to the plan and connect it to the left and right hand side operators.
NotExpression(OperatorPlan plan, LogicalExpression exp)
OrExpression(OperatorPlan plan, LogicalExpression lhs, LogicalExpression rhs) Will add this operator to the plan and connect it to the left and right hand side operators.
ProjectExpression(OperatorPlan plan, int inputNum, int colNum, LogicalRelationalOperator attachedRelationalOp) Adds projection to the plan.
ProjectExpression(OperatorPlan plan, int inputNum, LogicalRelationalOperator attachedRelationalOp) Constructor for range projection Adds projection to the plan.
ProjectExpression(OperatorPlan plan, int inputNum, String alias, Operator projectedOp, LogicalRelationalOperator attachedRelationalOp) Adds projection to the plan.
ProjectExpression(ProjectExpression projExpr, OperatorPlan plan) like a copy constructor, but with a plan argument
RegexExpression(OperatorPlan plan, LogicalExpression lhs, LogicalExpression rhs) Will add this operator to the plan and connect it to the left and right hand side operators.
ScalarExpression(OperatorPlan plan)
ScalarExpression(OperatorPlan plan, Operator implicitReferencedOperator, Operator attachedLogicalOperator)
SubtractExpression(OperatorPlan plan, LogicalExpression lhs, LogicalExpression rhs) Will add this operator to the plan and connect it to the left and right hand side operators.
UnaryExpression(String name, OperatorPlan plan, LogicalExpression exp) Will add this operator to the plan and connect it to the left and right hand side operators.
UserFuncExpression(OperatorPlan plan, FuncSpec funcSpec)
UserFuncExpression(OperatorPlan plan, FuncSpec funcSpec, boolean viaDefine)
UserFuncExpression(OperatorPlan plan, FuncSpec funcSpec, List<LogicalExpression> args)
UserFuncExpression(OperatorPlan plan, FuncSpec funcSpec, List<LogicalExpression> args, boolean viaDefine)
UserFuncExpression(OperatorPlan plan, FuncSpec funcSpec, List<LogicalExpression> args, boolean viaDefine, boolean lazilyInitializeInvokerFunction, boolean invokerIsStatic, String packageName, String funcName)

Uses of OperatorPlan in org.apache.pig.newplan.logical.optimizer

Methods in org.apache.pig.newplan.logical.optimizer with parameters of type OperatorPlan

Modifier and Type	Method and Description
void	SchemaPatcher.transformed(OperatorPlan fp, OperatorPlan tp)
void	ProjectionPatcher.transformed(OperatorPlan fp, OperatorPlan tp)

Constructors in org.apache.pig.newplan.logical.optimizer with parameters of type OperatorPlan

Constructor and Description
AllExpressionVisitor(OperatorPlan plan, PlanWalker walker)
AllSameRalationalNodesVisitor(OperatorPlan plan, PlanWalker walker)
LogicalPlanOptimizer(OperatorPlan p, int iterations, Set<String> turnOffRules)
LogicalPlanOptimizer(OperatorPlan p, int iterations, Set<String> turnOffRules, PigContext pc) Create a new LogicalPlanOptimizer.
LogicalPlanPrinter(OperatorPlan plan, PrintStream ps)
ProjectionFinder(OperatorPlan plan)
SchemaResetter(OperatorPlan plan)
SchemaResetter(OperatorPlan plan, boolean skipDuplicateUidCheck)
UidResetter(OperatorPlan plan)

Uses of OperatorPlan in org.apache.pig.newplan.logical.relational

Classes in org.apache.pig.newplan.logical.relational that implement OperatorPlan

Modifier and Type	Class and Description
class	LogicalPlan LogicalPlan is the logical view of relational operations Pig will execute for a given script.

Methods in org.apache.pig.newplan.logical.relational with parameters of type OperatorPlan

Modifier and Type	Method and Description
boolean	LogicalPlan.isEqual(OperatorPlan other) Equality is checked by calling equals on every leaf in the plan.
boolean	MapSideMergeValidator.validateMapSideMerge(List<Operator> preds, OperatorPlan lp)

Constructors in org.apache.pig.newplan.logical.relational with parameters of type OperatorPlan

Constructor and Description
LOCogroup(OperatorPlan plan, MultiMap<Integer,LogicalExpressionPlan> expressionPlans, boolean[] isInner)
LOCogroup(OperatorPlan plan, MultiMap<Integer,LogicalExpressionPlan> expressionPlans, LOCogroup.GROUPTYPE groupType, boolean[] isInner)
LOCube(OperatorPlan plan, MultiMap<Integer,LogicalExpressionPlan> expressionPlans)
LOForEach(OperatorPlan plan)
LOGenerate(OperatorPlan plan)
LOGenerate(OperatorPlan plan, List<LogicalExpressionPlan> ps, boolean[] flatten)
LogicalRelationalNodesVisitor(OperatorPlan plan, PlanWalker walker)
LogicalRelationalOperator(String name, OperatorPlan plan)
LogicalRelationalOperator(String name, OperatorPlan plan, int rp)
LogToPhyTranslationVisitor(OperatorPlan plan)
LOInnerLoad(OperatorPlan plan, LOForEach foreach, int colNum)
LOInnerLoad(OperatorPlan plan, LOForEach foreach, String colAlias)
LONative(OperatorPlan plan, String nativeJar, String[] parameters)
LORank(OperatorPlan plan)
LORank(OperatorPlan plan, List<LogicalExpressionPlan> rankColPlans, List<Boolean> ascCols)
LOSort(OperatorPlan plan)
LOSort(OperatorPlan plan, List<LogicalExpressionPlan> sortColPlans, List<Boolean> ascCols, FuncSpec sortFunc)
LOSplit(OperatorPlan plan)
LOUnion(OperatorPlan plan)
LOUnion(OperatorPlan plan, boolean onSchema)

Uses of OperatorPlan in org.apache.pig.newplan.logical.rules

Methods in org.apache.pig.newplan.logical.rules that return OperatorPlan

Modifier and Type	Method and Description
protected OperatorPlan	WholePlanRule.buildPattern()
protected OperatorPlan	StreamTypeCastInserter.buildPattern()
protected OperatorPlan	SplitFilter.buildPattern()
protected OperatorPlan	PushUpFilter.buildPattern()
protected OperatorPlan	PushDownForEachFlatten.buildPattern()
protected OperatorPlan	PredicatePushdownOptimizer.buildPattern()
protected OperatorPlan	PartitionFilterOptimizer.buildPattern()
protected OperatorPlan	NestedLimitOptimizer.buildPattern()
protected OperatorPlan	MergeForEach.buildPattern()
protected OperatorPlan	MergeFilter.buildPattern()
protected OperatorPlan	LoadTypeCastInserter.buildPattern()
protected OperatorPlan	LimitOptimizer.buildPattern()
protected OperatorPlan	GroupByConstParallelSetter.buildPattern()
protected OperatorPlan	ForEachConstantCalculator.buildPattern()
protected OperatorPlan	FilterConstantCalculator.buildPattern()
protected OperatorPlan	FilterAboveForeach.buildPattern()
OperatorPlan	TypeCastInserter.TypeCastInserterTransformer.reportChanges()
OperatorPlan	SplitFilter.SplitFilterTransformer.reportChanges()
OperatorPlan	PushUpFilter.PushUpFilterTransformer.reportChanges()
OperatorPlan	PartitionFilterOptimizer.PartitionFilterPushDownTransformer.reportChanges()
OperatorPlan	NestedLimitOptimizer.OptimizeNestedLimitTransformer.reportChanges()
OperatorPlan	MergeForEach.MergeForEachTransformer.reportChanges()
OperatorPlan	MergeFilter.MergeFilterTransformer.reportChanges()
OperatorPlan	MapKeysPruneHelper.reportChanges()
OperatorPlan	LimitOptimizer.OptimizeLimitTransformer.reportChanges()
OperatorPlan	GroupByConstParallelSetter.GroupAllParallelSetterTransformer.reportChanges()
OperatorPlan	FilterAboveForeach.FilterAboveForEachTransformer.reportChanges()
OperatorPlan	ConstantCalculator.ConstantCalculatorTransformer.reportChanges()
OperatorPlan	ColumnPruneHelper.reportChanges()
OperatorPlan	ColumnMapKeyPrune.ColumnMapKeyPruneTransformer.reportChanges()
OperatorPlan	AddForEach.AddForEachTransformer.reportChanges()

Methods in org.apache.pig.newplan.logical.rules that return types with arguments of type OperatorPlan

Modifier and Type	Method and Description
List<OperatorPlan>	WholePlanRule.match(OperatorPlan plan)

Methods in org.apache.pig.newplan.logical.rules with parameters of type OperatorPlan

Modifier and Type	Method and Description
boolean	TypeCastInserter.TypeCastInserterTransformer.check(OperatorPlan matched)
boolean	SplitFilter.SplitFilterTransformer.check(OperatorPlan matched)
boolean	PushUpFilter.PushUpFilterTransformer.check(OperatorPlan matched)
boolean	PartitionFilterOptimizer.PartitionFilterPushDownTransformer.check(OperatorPlan matched)
boolean	NestedLimitOptimizer.OptimizeNestedLimitTransformer.check(OperatorPlan matched)
boolean	MergeForEach.MergeForEachTransformer.check(OperatorPlan matched)
boolean	MergeFilter.MergeFilterTransformer.check(OperatorPlan matched)
boolean	LimitOptimizer.OptimizeLimitTransformer.check(OperatorPlan matched)
boolean	GroupByConstParallelSetter.GroupAllParallelSetterTransformer.check(OperatorPlan matched)
boolean	FilterAboveForeach.FilterAboveForEachTransformer.check(OperatorPlan matched)
boolean	ConstantCalculator.ConstantCalculatorTransformer.check(OperatorPlan matched)
boolean	ColumnMapKeyPrune.ColumnMapKeyPruneTransformer.check(OperatorPlan matched)
boolean	AddForEach.AddForEachTransformer.check(OperatorPlan matched)
List<OperatorPlan>	WholePlanRule.match(OperatorPlan plan)
void	TypeCastInserter.TypeCastInserterTransformer.transform(OperatorPlan matched)
void	SplitFilter.SplitFilterTransformer.transform(OperatorPlan matched)
void	PushUpFilter.PushUpFilterTransformer.transform(OperatorPlan matched)
void	PartitionFilterOptimizer.PartitionFilterPushDownTransformer.transform(OperatorPlan matched)
void	NestedLimitOptimizer.OptimizeNestedLimitTransformer.transform(OperatorPlan matched)
void	MergeForEach.MergeForEachTransformer.transform(OperatorPlan matched)
void	MergeFilter.MergeFilterTransformer.transform(OperatorPlan matched)
void	LimitOptimizer.OptimizeLimitTransformer.transform(OperatorPlan matched)
void	GroupByConstParallelSetter.GroupAllParallelSetterTransformer.transform(OperatorPlan plan)
void	FilterAboveForeach.FilterAboveForEachTransformer.transform(OperatorPlan matched)
void	ConstantCalculator.ConstantCalculatorTransformer.transform(OperatorPlan matched)
void	ColumnMapKeyPrune.ColumnMapKeyPruneTransformer.transform(OperatorPlan matched)
void	AddForEach.AddForEachTransformer.transform(OperatorPlan matched)

Constructors in org.apache.pig.newplan.logical.rules with parameters of type OperatorPlan

Constructor and Description
ColumnPruneHelper(OperatorPlan currentPlan)
ColumnPruneVisitor(OperatorPlan plan, Map<LOLoad,Pair<Map<Integer,Set<String>>,Set<Integer>>> requiredItems, boolean columnPrune)
ConstantCalculatorExpressionVisitor(OperatorPlan expPlan, LogicalRelationalOperator currentOp, PigContext pc)
ConstantCalculatorLogicalPlanVisitor(OperatorPlan plan, PigContext pc)
FullMapCollector(OperatorPlan plan, Set<Long> fullMapUids)
MapKeysPruneHelper(OperatorPlan currentPlan)
MapMarker(OperatorPlan plan)

Uses of OperatorPlan in org.apache.pig.newplan.logical.visitor

Constructors in org.apache.pig.newplan.logical.visitor with parameters of type OperatorPlan

Constructor and Description
ColumnAliasConversionVisitor(OperatorPlan plan)
DanglingNestedNodeRemover(OperatorPlan plan)
DuplicateForEachColumnRewriteVisitor(OperatorPlan plan)
ForEachUserSchemaVisitor(OperatorPlan plan)
InputOutputFileValidatorVisitor(OperatorPlan plan, PigContext pigContext)
LineageFindRelVisitor(OperatorPlan plan)
ProjectFinder(OperatorPlan p, PlanWalker walker)
ProjectStarExpander(OperatorPlan plan)
ProjStarInUdfExpander(OperatorPlan plan)
ScalarVariableValidator(OperatorPlan plan)
ScalarVisitor(OperatorPlan plan, PigContext pigContext, String scope)
SchemaAliasVisitor(OperatorPlan plan)
SortInfoSetter(OperatorPlan plan)
StoreAliasSetter(OperatorPlan plan)
TypeCheckingExpVisitor(OperatorPlan expPlan, CompilationMessageCollector msgCollector, LogicalRelationalOperator relOp)
TypeCheckingRelVisitor(OperatorPlan plan, CompilationMessageCollector msgCollector)
UDFFinder(OperatorPlan plan)
UnionOnSchemaSetter(OperatorPlan plan)

Uses of OperatorPlan in org.apache.pig.newplan.optimizer

Fields in org.apache.pig.newplan.optimizer declared as OperatorPlan

Modifier and Type	Field and Description
protected OperatorPlan	Rule.currentPlan
protected OperatorPlan	Rule.pattern
protected OperatorPlan	PlanOptimizer.plan

Methods in org.apache.pig.newplan.optimizer that return OperatorPlan

Modifier and Type	Method and Description
protected abstract OperatorPlan	Rule.buildPattern() Build the pattern that this rule will look for
OperatorPlan	Rule.getPattern() Return the pattern to be matched for this rule
abstract OperatorPlan	Transformer.reportChanges() Report what parts of the tree were transformed.

Methods in org.apache.pig.newplan.optimizer that return types with arguments of type OperatorPlan

Modifier and Type	Method and Description
List<OperatorPlan>	Rule.match(OperatorPlan plan) Search for all the sub-plans that matches the pattern defined by this rule.

Methods in org.apache.pig.newplan.optimizer with parameters of type OperatorPlan

Modifier and Type	Method and Description
abstract boolean	Transformer.check(OperatorPlan matched) check if the transform should be done.
List<OperatorPlan>	Rule.match(OperatorPlan plan) Search for all the sub-plans that matches the pattern defined by this rule.
abstract void	Transformer.transform(OperatorPlan matched) Transform the tree
void	PlanTransformListener.transformed(OperatorPlan fp, OperatorPlan tp) Notification that a plan has been transformed.

Constructors in org.apache.pig.newplan.optimizer with parameters of type OperatorPlan

Constructor and Description
PlanOptimizer(OperatorPlan p, List<Set<Rule>> rs, int iterations)
Rule(String n, OperatorPlan p)

Uses of OperatorPlan in org.apache.pig.pen

Constructors in org.apache.pig.pen with parameters of type OperatorPlan

Constructor and Description
AugmentBaseDataVisitor(OperatorPlan plan, Map<Operator,PhysicalOperator> logToPhysMap, Map<LOLoad,DataBag> baseData, Map<Operator,DataBag> derivedData)
POOptimizeDisabler(OperatorPlan plan)

Uses of OperatorPlan in org.apache.pig.pen.util

Methods in org.apache.pig.pen.util with parameters of type OperatorPlan

Modifier and Type	Method and Description
PlanWalker	PreOrderDepthFirstWalker.spawnChildWalker(OperatorPlan plan)

Constructors in org.apache.pig.pen.util with parameters of type OperatorPlan

Constructor and Description
PreOrderDepthFirstWalker(OperatorPlan plan)

Uses of OperatorPlan in org.apache.pig.tools.pigstats

Classes in org.apache.pig.tools.pigstats that implement OperatorPlan

Modifier and Type	Class and Description
static class	PigStats.JobGraph JobGraph is an OperatorPlan whose members are JobStats

Constructors in org.apache.pig.tools.pigstats with parameters of type OperatorPlan

Constructor and Description
JobGraphPrinter(OperatorPlan plan)

Uses of OperatorPlan in org.apache.pig.validator

Constructors in org.apache.pig.validator with parameters of type OperatorPlan

Constructor and Description
BlackAndWhitelistValidator(PigContext pigContext, OperatorPlan operatorPlan)