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

Packages that use OperatorPlan

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

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

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

PatternNode(OperatorPlan p)

Uses of OperatorPlan in org.apache.pig.newplan

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

class	BaseOperatorPlan
class	OperatorSubPlan Class to represent a view of a plan.

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

protected OperatorPlan	PlanWalker.plan
protected OperatorPlan	PlanVisitor.plan
protected OperatorPlan	Operator.plan

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

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

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

DependencyOrderWalker(OperatorPlan plan)

DepthFirstWalker(OperatorPlan plan)

Operator(String n, OperatorPlan p)

OperatorSubPlan(OperatorPlan base)

PColFilterExtractor(OperatorPlan plan, List<String> partitionCols)

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

class

LogicalExpressionPlan A plan containing LogicalExpressionOperators.

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

boolean

LogicalExpressionPlan.isEqual(OperatorPlan other)

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

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, 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, List<LogicalExpression> args)

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

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

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

AllExpressionVisitor(OperatorPlan plan, PlanWalker walker)

AllSameRalationalNodesVisitor(OperatorPlan plan, PlanWalker walker)

DanglingNestedNodeRemover(OperatorPlan plan)

LogicalPlanOptimizer(OperatorPlan p, int iterations, Set<String> turnOffRules)

LogicalPlanPrinter(OperatorPlan plan, PrintStream ps)

ProjectionPatcher.ProjectionFinder(OperatorPlan plan)

SchemaResetter(OperatorPlan plan)

UidResetter(OperatorPlan plan)

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

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

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

boolean

LogicalPlan.isEqual(OperatorPlan other) Equality is checked by calling equals on every leaf in the plan.

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

LOCogroup(OperatorPlan plan, MultiMap<Integer,LogicalExpressionPlan> expressionPlans, boolean[] isInner)

LOCogroup(OperatorPlan plan, MultiMap<Integer,LogicalExpressionPlan> expressionPlans, LOCogroup.GROUPTYPE groupType, boolean[] isInner)

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)

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

protected OperatorPlan	WholePlanRule.buildPattern()
protected OperatorPlan	TypeCastInserter.buildPattern()
protected OperatorPlan	SplitFilter.buildPattern()
protected OperatorPlan	PushUpFilter.buildPattern()
protected OperatorPlan	PushDownForEachFlatten.buildPattern()
protected OperatorPlan	PartitionFilterOptimizer.buildPattern()
protected OperatorPlan	MergeForEach.buildPattern()
protected OperatorPlan	MergeFilter.buildPattern()
protected OperatorPlan	LogicalExpressionSimplifier.buildPattern()
protected OperatorPlan	LimitOptimizer.buildPattern()
protected OperatorPlan	ImplicitSplitInserter.buildPattern()
protected OperatorPlan	GroupByConstParallelSetter.buildPattern()
protected OperatorPlan	FilterAboveForeach.buildPattern()
protected OperatorPlan	DuplicateForEachColumnRewrite.buildPattern()
OperatorPlan	TypeCastInserter.TypeCastInserterTransformer.reportChanges()
OperatorPlan	SplitFilter.SplitFilterTransformer.reportChanges()
OperatorPlan	PushUpFilter.PushUpFilterTransformer.reportChanges()
OperatorPlan	PartitionFilterOptimizer.PartitionFilterPushDownTransformer.reportChanges()
OperatorPlan	MergeForEach.MergeForEachTransformer.reportChanges()
OperatorPlan	MergeFilter.MergeFilterTransformer.reportChanges()
OperatorPlan	MapKeysPruneHelper.reportChanges()
OperatorPlan	LogicalExpressionSimplifier.LogicalExpressionSimplifierTransformer.reportChanges()
OperatorPlan	LimitOptimizer.OptimizeLimitTransformer.reportChanges()
OperatorPlan	ImplicitSplitInserter.ImplicitSplitInserterTransformer.reportChanges()
OperatorPlan	GroupByConstParallelSetter.GroupAllParallelSetterTransformer.reportChanges()
OperatorPlan	FilterAboveForeach.FilterAboveForEachTransformer.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

List<OperatorPlan>	WholePlanRule.match(OperatorPlan plan)
List<OperatorPlan>	ImplicitSplitInserter.match(OperatorPlan plan)

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

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	MergeForEach.MergeForEachTransformer.check(OperatorPlan matched)
boolean	MergeFilter.MergeFilterTransformer.check(OperatorPlan matched)
boolean	LogicalExpressionSimplifier.LogicalExpressionSimplifierTransformer.check(OperatorPlan matched)
boolean	LimitOptimizer.OptimizeLimitTransformer.check(OperatorPlan matched)
boolean	ImplicitSplitInserter.ImplicitSplitInserterTransformer.check(OperatorPlan matched)
boolean	GroupByConstParallelSetter.GroupAllParallelSetterTransformer.check(OperatorPlan matched)
boolean	FilterAboveForeach.FilterAboveForEachTransformer.check(OperatorPlan matched)
boolean	ColumnMapKeyPrune.ColumnMapKeyPruneTransformer.check(OperatorPlan matched)
boolean	AddForEach.AddForEachTransformer.check(OperatorPlan matched)
List<OperatorPlan>	WholePlanRule.match(OperatorPlan plan)
List<OperatorPlan>	ImplicitSplitInserter.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	MergeForEach.MergeForEachTransformer.transform(OperatorPlan matched)
void	MergeFilter.MergeFilterTransformer.transform(OperatorPlan matched)
void	LogicalExpressionSimplifier.LogicalExpressionSimplifierTransformer.transform(OperatorPlan plan)
void	LimitOptimizer.OptimizeLimitTransformer.transform(OperatorPlan matched)
void	ImplicitSplitInserter.ImplicitSplitInserterTransformer.transform(OperatorPlan matched)
void	GroupByConstParallelSetter.GroupAllParallelSetterTransformer.transform(OperatorPlan plan)
void	FilterAboveForeach.FilterAboveForEachTransformer.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

ColumnPruneHelper(OperatorPlan currentPlan)

ColumnPruneVisitor(OperatorPlan plan, Map<LOLoad,Pair<Map<Integer,Set<String>>,Set<Integer>>> requiredItems, boolean columnPrune)

InputOutputFileValidator(OperatorPlan plan, PigContext pigContext)

LoadStoreFuncDupSignatureValidator(OperatorPlan plan)

MapKeysPruneHelper.FullMapCollector(OperatorPlan plan, Set<Long> fullMapUids)

MapKeysPruneHelper.MapMarker(OperatorPlan plan)

MapKeysPruneHelper(OperatorPlan currentPlan)

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

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

ColumnAliasConversionVisitor(OperatorPlan plan)

LineageFindRelVisitor(OperatorPlan plan)

ProjectStarExpander(OperatorPlan plan)

ProjStarInUdfExpander(OperatorPlan plan)

ScalarVisitor(OperatorPlan plan, PigContext pigContext)

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

protected OperatorPlan	Rule.currentPlan
protected OperatorPlan	Rule.pattern
protected OperatorPlan	PlanOptimizer.plan

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

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

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

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

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

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

PlanWalker

PreOrderDepthFirstWalker.spawnChildWalker(OperatorPlan plan)

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

PreOrderDepthFirstWalker(OperatorPlan plan)

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

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

static class

PigStats.JobGraph JobGraph is an OperatorPlan whose members are JobStats