Uses of Class
org.apache.pig.backend.hadoop.executionengine.physicalLayer.plans.PhysicalPlan

Packages that use PhysicalPlan

org.apache.pig.backend.hadoop.executionengine
org.apache.pig.backend.hadoop.executionengine.fetch
org.apache.pig.backend.hadoop.executionengine.mapReduceLayer
org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.plans
org.apache.pig.backend.hadoop.executionengine.physicalLayer	Implementation of physical operators that use hadoop as the execution engine and data storage.
org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators
org.apache.pig.backend.hadoop.executionengine.physicalLayer.plans
org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators
org.apache.pig.backend.hadoop.executionengine.physicalLayer.util
org.apache.pig.backend.hadoop.executionengine.util
org.apache.pig.impl.util
org.apache.pig.newplan.logical.expression
org.apache.pig.newplan.logical.relational
org.apache.pig.pen
org.apache.pig.tools.pigstats

Uses of PhysicalPlan in org.apache.pig.backend.hadoop.executionengine

Methods in org.apache.pig.backend.hadoop.executionengine that return PhysicalPlan

PhysicalPlan

HExecutionEngine.compile(LogicalPlan plan, Properties properties)

Methods in org.apache.pig.backend.hadoop.executionengine with parameters of type PhysicalPlan

abstract void	Launcher.explain(PhysicalPlan pp, PigContext pc, PrintStream ps, String format, boolean verbose) Explain how a pig job will be executed on the underlying infrastructure.
abstract PigStats	Launcher.launchPig(PhysicalPlan php, String grpName, PigContext pc) Method to launch pig for hadoop either for a cluster's job tracker or for a local job runner.

Uses of PhysicalPlan in org.apache.pig.backend.hadoop.executionengine.fetch

Methods in org.apache.pig.backend.hadoop.executionengine.fetch with parameters of type PhysicalPlan

void	FetchLauncher.explain(PhysicalPlan pp, PigContext pc, PrintStream ps, String format) Creates an empty MR plan
static boolean	FetchOptimizer.isPlanFetchable(PigContext pc, PhysicalPlan pp) Visits the plan with FetchablePlanVisitor and checks whether the plan is fetchable.
PigStats	FetchLauncher.launchPig(PhysicalPlan pp) Runs the fetch task by executing chain of calls on the PhysicalPlan from the leaf up to the LoadFunc

Uses of PhysicalPlan in org.apache.pig.backend.hadoop.executionengine.mapReduceLayer

Fields in org.apache.pig.backend.hadoop.executionengine.mapReduceLayer declared as PhysicalPlan

PhysicalPlan	MapReduceOper.combinePlan
PhysicalPlan	MapReduceOper.mapPlan
protected PhysicalPlan	PigGenericMapBase.mp
PhysicalPlan	MapReduceOper.reducePlan
protected PhysicalPlan	PigGenericMapReduce.Reduce.rp

Methods in org.apache.pig.backend.hadoop.executionengine.mapReduceLayer that return PhysicalPlan

PhysicalPlan

MRCompiler.getPlan() Used to get the plan that was compiled

Methods in org.apache.pig.backend.hadoop.executionengine.mapReduceLayer with parameters of type PhysicalPlan

MROperPlan	MapReduceLauncher.compile(PhysicalPlan php, PigContext pc)
void	MapReduceLauncher.explain(PhysicalPlan php, PigContext pc, PrintStream ps, String format, boolean verbose)
PigStats	MapReduceLauncher.launchPig(PhysicalPlan php, String grpName, PigContext pc)
void	PigGenericMapBase.setMapPlan(PhysicalPlan plan) for local map/reduce simulation
void	PigGenericMapReduce.Reduce.setReducePlan(PhysicalPlan plan) Set the reduce plan: to be used by local runner for illustrator

Constructors in org.apache.pig.backend.hadoop.executionengine.mapReduceLayer with parameters of type PhysicalPlan

MRCompiler(PhysicalPlan plan)

MRCompiler(PhysicalPlan plan, PigContext pigContext)

PhyPlanSetter(PhysicalPlan plan)

UDFFinishVisitor(PhysicalPlan plan, PlanWalker<PhysicalOperator,PhysicalPlan> walker)

Constructor parameters in org.apache.pig.backend.hadoop.executionengine.mapReduceLayer with type arguments of type PhysicalPlan

UDFFinishVisitor(PhysicalPlan plan, PlanWalker<PhysicalOperator,PhysicalPlan> walker)

Uses of PhysicalPlan in org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.plans

Methods in org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.plans that return PhysicalPlan

PhysicalPlan

DotMRPrinter.InnerOperator.getPlan()

Methods in org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.plans with parameters of type PhysicalPlan

void	UDFFinder.setPlan(PhysicalPlan plan)

Constructors in org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.plans with parameters of type PhysicalPlan

DotMRPrinter.InnerOperator(PhysicalPlan plan, String name)

DotMRPrinter.InnerPlan(PhysicalPlan mapPlan, PhysicalPlan combinePlan, PhysicalPlan reducePlan)

ScalarPhyFinder(PhysicalPlan plan)

UDFFinder(PhysicalPlan plan, PlanWalker<PhysicalOperator,PhysicalPlan> walker)

Constructor parameters in org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.plans with type arguments of type PhysicalPlan

UDFFinder(PhysicalPlan plan, PlanWalker<PhysicalOperator,PhysicalPlan> walker)

Uses of PhysicalPlan in org.apache.pig.backend.hadoop.executionengine.physicalLayer

Fields in org.apache.pig.backend.hadoop.executionengine.physicalLayer declared as PhysicalPlan

protected PhysicalPlan

PhysicalOperator.parentPlan

Methods in org.apache.pig.backend.hadoop.executionengine.physicalLayer with parameters of type PhysicalPlan

void	PhysicalOperator.setParentPlan(PhysicalPlan physicalPlan)

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

POPrinter(PrintStream ps, PhysicalPlan pp)

Uses of PhysicalPlan in org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators

Methods in org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators with parameters of type PhysicalPlan

void	UnaryExpressionOperator.setInputAsExpr(PhysicalPlan plan) Set the contained expression to the be the input value.

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

Methods in org.apache.pig.backend.hadoop.executionengine.physicalLayer.plans that return PhysicalPlan

PhysicalPlan

PhysicalPlan.clone()

Methods in org.apache.pig.backend.hadoop.executionengine.physicalLayer.plans that return types with arguments of type PhysicalPlan

protected Collection<PhysicalPlan>	DotPOPrinter.getMultiOutputNestedPlans(PhysicalOperator op)
protected Collection<PhysicalPlan>	DotPOPrinter.getNestedPlans(PhysicalOperator op)

Methods in org.apache.pig.backend.hadoop.executionengine.physicalLayer.plans with parameters of type PhysicalPlan

protected DotPlanDumper

DotPOPrinter.makeDumper(PhysicalPlan plan, PrintStream ps)

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

DotPOPrinter(PhysicalPlan plan, PrintStream ps)

DotPOPrinter(PhysicalPlan plan, PrintStream ps, boolean isSubGraph, Set<Operator> subgraphs, Set<Operator> multiInputSubgraphs, Set<Operator> multiOutputSubgraphs)

PhyPlanVisitor(PhysicalPlan plan, PlanWalker<PhysicalOperator,PhysicalPlan> walker)

XMLPhysicalPlanPrinter(PhysicalPlan plan, Document doc, Element parent)

Constructor parameters in org.apache.pig.backend.hadoop.executionengine.physicalLayer.plans with type arguments of type PhysicalPlan

PhyPlanVisitor(PhysicalPlan plan, PlanWalker<PhysicalOperator,PhysicalPlan> walker)

Uses of PhysicalPlan in org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators

Fields in org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators with type parameters of type PhysicalPlan

protected List<PhysicalPlan>	POForEach.inputPlans
protected List<PhysicalPlan>	POPreCombinerLocalRearrange.plans
protected List<PhysicalPlan>	POLocalRearrange.plans
protected List<PhysicalPlan>	POCollectedGroup.plans
protected List<PhysicalPlan>	POLocalRearrange.secondaryPlans

Methods in org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators that return PhysicalPlan

PhysicalPlan	POPartialAgg.getKeyPlan()
PhysicalPlan	POLimit.getLimitPlan()
PhysicalPlan	POFilter.getPlan()

Methods in org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators that return types with arguments of type PhysicalPlan

List<PhysicalPlan>	POCounter.getCounterPlans()
List<PhysicalPlan>	POMergeJoin.getInnerPlansOf(int index)
List<PhysicalPlan>	POForEach.getInputPlans()
List<PhysicalPlan>	JoinPackager.getInputPlans()
MultiMap<PhysicalOperator,PhysicalPlan>	POSkewedJoin.getJoinPlans()
List<List<PhysicalPlan>>	POFRJoin.getJoinPlans()
List<PhysicalPlan>	POMergeCogroup.getLRInnerPlansOf(int i)
List<PhysicalPlan>	POSplit.getPlans() Returns the list of nested plans.
List<PhysicalPlan>	POPreCombinerLocalRearrange.getPlans()
List<PhysicalPlan>	POLocalRearrange.getPlans()
List<PhysicalPlan>	PODemux.getPlans() Returns the list of inner plans.
List<PhysicalPlan>	POCollectedGroup.getPlans()
List<PhysicalPlan>	PORank.getRankPlans()
List<PhysicalPlan>	POSort.getSortPlans()
List<PhysicalPlan>	POPartialAgg.getValuePlans()

Methods in org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators with parameters of type PhysicalPlan

void	POForEach.addInputPlan(PhysicalPlan plan, boolean flatten)
void	POSplit.addPlan(PhysicalPlan inPlan) Appends the specified plan to the end of the nested input plan list
void	PODemux.addPlan(PhysicalPlan inPlan) Appends the specified plan at the end of the list.
void	POSplit.removePlan(PhysicalPlan plan) Removes plan from the nested input plan list
void	POPartialAgg.setKeyPlan(PhysicalPlan keyPlan)
void	POLimit.setLimitPlan(PhysicalPlan expressionPlan)
void	POFilter.setPlan(PhysicalPlan plan)
void	POMergeJoin.setupRightPipeline(PhysicalPlan rightPipeline)

Method parameters in org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators with type arguments of type PhysicalPlan

void	POCounter.setCounterPlans(List<PhysicalPlan> counterPlans)
void	POForEach.setInputPlans(List<PhysicalPlan> plans)
void	JoinPackager.setInputPlans(List<PhysicalPlan> plans)
void	POSkewedJoin.setJoinPlans(MultiMap<PhysicalOperator,PhysicalPlan> joinPlans)
void	POPreCombinerLocalRearrange.setPlans(List<PhysicalPlan> plans)
void	POLocalRearrange.setPlans(List<PhysicalPlan> plans)
void	POCollectedGroup.setPlans(List<PhysicalPlan> plans)
void	POLocalRearrange.setPlansFromCombiner(List<PhysicalPlan> plans)
void	PORank.setRankPlans(List<PhysicalPlan> rankPlans)
void	POLocalRearrange.setSecondaryPlans(List<PhysicalPlan> plans)
void	POSort.setSortPlans(List<PhysicalPlan> sortPlans)
void	POPartialAgg.setValuePlans(List<PhysicalPlan> valuePlans)

Constructor parameters in org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators with type arguments of type PhysicalPlan

POCounter(OperatorKey operatorKey, int requestedParallelism, List inp, List<PhysicalPlan> counterPlans, List<Boolean> ascendingCol)

POForEach(OperatorKey k, int rp, List<PhysicalPlan> inp, List<Boolean> isToBeFlattened)

POForEach(OperatorKey operatorKey, int requestedParallelism, List<PhysicalPlan> innerPlans, List<Boolean> flattenList, Schema schema)

POFRJoin(OperatorKey k, int rp, List<PhysicalOperator> inp, List<List<PhysicalPlan>> ppLists, List<List<Byte>> keyTypes, FileSpec[] replFiles, int fragment, boolean isLeftOuter, Tuple nullTuple)

POFRJoin(OperatorKey k, int rp, List<PhysicalOperator> inp, List<List<PhysicalPlan>> ppLists, List<List<Byte>> keyTypes, FileSpec[] replFiles, int fragment, boolean isLeftOuter, Tuple nullTuple, Schema[] inputSchemas, Schema[] keySchemas)

POMergeJoin(OperatorKey k, int rp, List<PhysicalOperator> inp, MultiMap<PhysicalOperator,PhysicalPlan> inpPlans, List<List<Byte>> keyTypes, LOJoin.JOINTYPE joinType, Schema leftInputSchema, Schema rightInputSchema, Schema mergedInputSchema)

POOptimizedForEach(OperatorKey k, int rp, List<PhysicalPlan> inp, List<Boolean> isToBeFlattened)

PORank(OperatorKey operatorKey, int requestedParallelism, List inp, List<PhysicalPlan> rankPlans, List<Boolean> ascendingCol)

POSort(OperatorKey k, int rp, List inp, List<PhysicalPlan> sortPlans, List<Boolean> mAscCols, POUserComparisonFunc mSortFunc)

Uses of PhysicalPlan in org.apache.pig.backend.hadoop.executionengine.physicalLayer.util

Methods in org.apache.pig.backend.hadoop.executionengine.physicalLayer.util with parameters of type PhysicalPlan

static <C extends PhysicalOperator> boolean	PlanHelper.containsPhysicalOperator(PhysicalPlan plan, Class<C> opClass)
static <C extends PhysicalOperator> LinkedList<C>	PlanHelper.getPhysicalOperators(PhysicalPlan plan, Class<C> opClass) Returns a LinkedList of operators contained within the physical plan which implement the supplied class, in dependency order.

Uses of PhysicalPlan in org.apache.pig.backend.hadoop.executionengine.util

Methods in org.apache.pig.backend.hadoop.executionengine.util with parameters of type PhysicalPlan

static FileSpec

MapRedUtil.checkLeafIsStore(PhysicalPlan plan, PigContext pigContext)

Uses of PhysicalPlan in org.apache.pig.impl.util

Methods in org.apache.pig.impl.util with parameters of type PhysicalPlan

static void

CompilerUtils.addEmptyBagOuterJoin(PhysicalPlan fePlan, Schema inputSchema)

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

Fields in org.apache.pig.newplan.logical.expression declared as PhysicalPlan

protected PhysicalPlan

ExpToPhyTranslationVisitor.currentPlan

Fields in org.apache.pig.newplan.logical.expression with type parameters of type PhysicalPlan

protected Deque<PhysicalPlan>

ExpToPhyTranslationVisitor.currentPlans

Methods in org.apache.pig.newplan.logical.expression that return PhysicalPlan

PhysicalPlan

ExpToPhyTranslationVisitor.getPhysicalPlan()

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

ExpToPhyTranslationVisitor(OperatorPlan plan, LogicalRelationalOperator op, PhysicalPlan phyPlan, Map<Operator,PhysicalOperator> map)

ExpToPhyTranslationVisitor(OperatorPlan plan, PlanWalker walker, LogicalRelationalOperator op, PhysicalPlan phyPlan, Map<Operator,PhysicalOperator> map)

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

Fields in org.apache.pig.newplan.logical.relational declared as PhysicalPlan

protected PhysicalPlan

LogToPhyTranslationVisitor.currentPlan

Fields in org.apache.pig.newplan.logical.relational with type parameters of type PhysicalPlan

protected Deque<PhysicalPlan>

LogToPhyTranslationVisitor.currentPlans

Methods in org.apache.pig.newplan.logical.relational that return PhysicalPlan

PhysicalPlan

LogToPhyTranslationVisitor.getPhysicalPlan()

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

static void

LogToPhyTranslationVisitor.updateWithEmptyBagCheck(PhysicalPlan fePlan, Operator joinInput) 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

Uses of PhysicalPlan in org.apache.pig.pen

Methods in org.apache.pig.pen with parameters of type PhysicalPlan

static Map<LogicalRelationalOperator,Collection<IdentityHashSet<Tuple>>>	EquivalenceClasses.getLoToEqClassMap(PhysicalPlan plan, LogicalPlan lp, Map<Operator,PhysicalOperator> logToPhyMap, Map<Operator,DataBag> logToDataMap, Map<LOForEach,Map<LogicalRelationalOperator,PhysicalOperator>> forEachInnerLogToPhyMap, HashMap<PhysicalOperator,Collection<IdentityHashSet<Tuple>>> poToEqclassesMap)
void	LocalMapReduceSimulator.launchPig(PhysicalPlan php, Map<LOLoad,DataBag> baseData, LineageTracer lineage, IllustratorAttacher attacher, ExampleGenerator eg, PigContext pc)
void	IllustratorAttacher.revisit(PhysicalPlan plan) revisit an enhanced physical plan from MR compilation

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

IllustratorAttacher(PhysicalPlan plan, LineageTracer lineage, int maxRecords, Map<POLoad,LogicalSchema> poLoadToSchemaMap, PigContext hadoopPigContext)

LineageTrimmingVisitor(LogicalPlan plan, Map<LOLoad,DataBag> baseData, ExampleGenerator eg, Map<Operator,PhysicalOperator> LogToPhyMap, PhysicalPlan physPlan, PigContext pc)

PhysicalPlanResetter(PhysicalPlan plan)

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

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

ScriptState.AliasVisitor(PhysicalPlan plan, List<String> alias, List<String> aliasLocation)

ScriptState.FeatureVisitor(PhysicalPlan plan, BitSet feature)