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

Packages that use PhysicalPlan
org.apache.pig Public interfaces and classes for Pig. 
org.apache.pig.backend.hadoop.executionengine   
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   
 

Uses of PhysicalPlan in org.apache.pig
 

Methods in org.apache.pig with parameters of type PhysicalPlan
protected  PigStats PigServer.launchPlan(PhysicalPlan pp, String jobName)
          A common method for launching the jobs according to the physical plan
 

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)
           
 

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)
           
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.
 PigStats MapReduceLauncher.launchPig(PhysicalPlan php, String grpName, PigContext pc)
           
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.
 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)
           
 

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 POFilter.getPlan()
           
 

Methods in org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators that return types with arguments of type PhysicalPlan
 List<PhysicalPlan> POMergeJoin.getInnerPlansOf(int index)
           
 List<PhysicalPlan> POJoinPackage.getInputPlans()
           
 List<PhysicalPlan> POForEach.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> POSort.getSortPlans()
           
 

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 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 POJoinPackage.setInputPlans(List<PhysicalPlan> plans)
           
 void POForEach.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 POLocalRearrange.setSecondaryPlans(List<PhysicalPlan> plans)
           
 void POSort.setSortPlans(List<PhysicalPlan> sortPlans)
           
 

Constructor parameters in org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators with type arguments of type PhysicalPlan
POForEach(OperatorKey k, int rp, List<PhysicalPlan> inp, List<Boolean> isToBeFlattened)
           
POFRJoin(OperatorKey k, int rp, List<PhysicalOperator> inp, List<List<PhysicalPlan>> ppLists, List<List<Byte>> keyTypes, FileSpec[] replFiles, int fragment, boolean isLeftOuter, Tuple nullTuple)
           
POMergeJoin(OperatorKey k, int rp, List<PhysicalOperator> inp, MultiMap<PhysicalOperator,PhysicalPlan> inpPlans, List<List<Byte>> keyTypes)
           
POOptimizedForEach(OperatorKey k, int rp, List<PhysicalPlan> inp, List<Boolean> isToBeFlattened)
           
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 LinkedList<POLoad> PlanHelper.getLoads(PhysicalPlan plan)
          Get all the load operators in the plan in the right dependency order
static LinkedList<PONative> PlanHelper.getNativeMRs(PhysicalPlan plan)
          Get all the load operators in the plan in the right dependency order
static LinkedList<POStore> PlanHelper.getStores(PhysicalPlan plan)
          Get all the store operators in the plan in the right 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  Stack<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  Stack<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)
           
 



Copyright © ${year} The Apache Software Foundation