org.apache.pig.backend.hadoop.executionengine.physicalLayer.util
Class PlanHelper

java.lang.Object
  extended by org.apache.pig.backend.hadoop.executionengine.physicalLayer.util.PlanHelper

public class PlanHelper
extends Object

Utility class with a few helper functions to deal with physical plans.


Method Summary
static LinkedList<POLoad> getLoads(PhysicalPlan plan)
          Get all the load operators in the plan in the right dependency order
static LinkedList<PONative> getNativeMRs(PhysicalPlan plan)
          Get all the load operators in the plan in the right dependency order
static LinkedList<POStore> getStores(PhysicalPlan plan)
          Get all the store operators in the plan in the right dependency order
static String makeStoreTmpPath(String orig)
          Creates a relative path that can be used to build a temporary place to store the output from a number of map-reduce tasks.
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Method Detail

getStores

public static LinkedList<POStore> getStores(PhysicalPlan plan)
                                     throws VisitorException
Get all the store operators in the plan in the right dependency order

Parameters:
plan -
Returns:
List of stores (could be empty)
Throws:
VisitorException

getLoads

public static LinkedList<POLoad> getLoads(PhysicalPlan plan)
                                   throws VisitorException
Get all the load operators in the plan in the right dependency order

Parameters:
plan -
Returns:
List of loads (could be empty)
Throws:
VisitorException

getNativeMRs

public static LinkedList<PONative> getNativeMRs(PhysicalPlan plan)
                                         throws VisitorException
Get all the load operators in the plan in the right dependency order

Parameters:
plan -
Returns:
List of loads (could be empty)
Throws:
VisitorException

makeStoreTmpPath

public static String makeStoreTmpPath(String orig)
Creates a relative path that can be used to build a temporary place to store the output from a number of map-reduce tasks.



Copyright © 2007-2012 The Apache Software Foundation