| Modifier and Type | Method and Description | 
|---|---|
| protected PigStats | PigServer. launchPlan(LogicalPlan lp,
          java.lang.String jobName)A common method for launching the jobs according to the logical plan | 
| static PigStats | PigRunner. run(java.lang.String[] args,
   PigProgressNotificationListener listener) | 
| Modifier and Type | Method and Description | 
|---|---|
| protected java.util.List<ExecJob> | PigServer. getJobs(PigStats stats)Retrieves a list of Job objects from the PigStats object | 
| Modifier and Type | Method and Description | 
|---|---|
| PigStats | ExecJob. getStatistics()Can be information about the state (not submitted, e.g. | 
| PigStats | ExecutionEngine. instantiatePigStats()Creates a PigStats object which will be accessible as a ThreadLocal
 variable inside the PigStats class. | 
| PigStats | ExecutionEngine. launchPig(LogicalPlan lp,
         java.lang.String grpName,
         PigContext pc)This method is responsible for the actual execution of a LogicalPlan. | 
| Modifier and Type | Method and Description | 
|---|---|
| PigStats | HJob. getStatistics() | 
| PigStats | HExecutionEngine. launchPig(LogicalPlan lp,
         java.lang.String grpName,
         PigContext pc) | 
| abstract PigStats | Launcher. launchPig(PhysicalPlan php,
         java.lang.String grpName,
         PigContext pc)Method to launch pig for hadoop either for a cluster's job tracker or for
 a local job runner. | 
| Constructor and Description | 
|---|
| HJob(ExecJob.JOB_STATUS status,
    PigContext pigContext,
    POStore store,
    java.lang.String alias,
    PigStats stats) | 
| Modifier and Type | Method and Description | 
|---|---|
| PigStats | FetchLauncher. launchPig(PhysicalPlan pp)Runs the fetch task by executing chain of calls on the PhysicalPlan from the leaf
 up to the LoadFunc | 
| Modifier and Type | Method and Description | 
|---|---|
| PigStats | MRExecutionEngine. instantiatePigStats() | 
| PigStats | MapReduceLauncher. launchPig(PhysicalPlan php,
         java.lang.String grpName,
         PigContext pc) | 
| Modifier and Type | Method and Description | 
|---|---|
| PigStats | SparkExecutionEngine. instantiatePigStats() | 
| PigStats | SparkLauncher. launchPig(PhysicalPlan physicalPlan,
         java.lang.String grpName,
         PigContext pigContext) | 
| Modifier and Type | Method and Description | 
|---|---|
| PigStats | TezExecutionEngine. instantiatePigStats() | 
| PigStats | TezLauncher. launchPig(PhysicalPlan php,
         java.lang.String grpName,
         PigContext pc) | 
| Modifier and Type | Method and Description | 
|---|---|
| PigStats | BoundScript. runSingle()Run a pipeline on Hadoop. | 
| PigStats | BoundScript. runSingle(java.util.Properties prop)Run a pipeline on Hadoop. | 
| PigStats | BoundScript. runSingle(java.lang.String propfile)Run a pipeline on Hadoop. | 
| Modifier and Type | Method and Description | 
|---|---|
| protected java.util.Map<java.lang.String,java.util.List<PigStats>> | ScriptEngine. getPigStatsMap()Gets the collection of  PigStatsafter the script is run. | 
| protected abstract java.util.Map<java.lang.String,java.util.List<PigStats>> | ScriptEngine. main(PigContext context,
    java.lang.String scriptFile)Actually runs the script file. | 
| java.util.List<PigStats> | BoundScript. run()Run multiple instances of bound pipeline on Hadoop in parallel. | 
| java.util.Map<java.lang.String,java.util.List<PigStats>> | ScriptEngine. run(PigContext pigContext,
   java.lang.String scriptFile)Runs a script file. | 
| java.util.List<PigStats> | BoundScript. run(java.util.Properties prop)Run multiple instances of bound pipeline on Hadoop in parallel. | 
| java.util.List<PigStats> | BoundScript. run(java.lang.String propfile)Run multiple instances of bound pipeline on Hadoop in parallel. | 
| Modifier and Type | Method and Description | 
|---|---|
| protected java.util.Map<java.lang.String,java.util.List<PigStats>> | GroovyScriptEngine. main(PigContext context,
    java.lang.String scriptFile) | 
| Modifier and Type | Method and Description | 
|---|---|
| protected java.util.Map<java.lang.String,java.util.List<PigStats>> | JrubyScriptEngine. main(PigContext pigContext,
    java.lang.String scriptFile) | 
| Modifier and Type | Method and Description | 
|---|---|
| protected java.util.Map<java.lang.String,java.util.List<PigStats>> | JsScriptEngine. main(PigContext pigContext,
    java.lang.String scriptFile) | 
| Modifier and Type | Method and Description | 
|---|---|
| protected java.util.Map<java.lang.String,java.util.List<PigStats>> | JythonScriptEngine. main(PigContext pigContext,
    java.lang.String scriptFile) | 
| Modifier and Type | Method and Description | 
|---|---|
| protected java.util.Map<java.lang.String,java.util.List<PigStats>> | PythonScriptEngine. main(PigContext context,
    java.lang.String scriptFile) | 
| Modifier and Type | Class and Description | 
|---|---|
| class  | EmptyPigStatsEmptyPigStats encapsulates dummy statistics of a fetch task, since during a
 fetch no MR jobs are executed | 
| Modifier and Type | Method and Description | 
|---|---|
| static PigStats | PigStats. get() | 
| static PigStats | PigStatsUtil. getEmptyPigStats()Deprecated.  | 
| static PigStats | PigStatsUtil. getPigStats(int code)Returns the PigStats with the given return code | 
| static PigStats | PigStats. start(PigStats stats) | 
| Modifier and Type | Method and Description | 
|---|---|
| abstract java.util.Map<java.lang.String,java.util.List<PigStats>> | PigStats. getAllStats() | 
| java.util.Map<java.lang.String,java.util.List<PigStats>> | EmptyPigStats. getAllStats() | 
| Modifier and Type | Method and Description | 
|---|---|
| static PigStats | PigStats. start(PigStats stats) | 
| Modifier and Type | Method and Description | 
|---|---|
| static void | PigStatsUtil. setStatsMap(java.util.Map<java.lang.String,java.util.List<PigStats>> statsMap) | 
| Modifier and Type | Class and Description | 
|---|---|
| class  | SimplePigStatsSimplePigStats encapsulates the statistics collected from a running script. | 
| Modifier and Type | Method and Description | 
|---|---|
| java.util.Map<java.lang.String,java.util.List<PigStats>> | SimplePigStats. getAllStats() | 
| Modifier and Type | Method and Description | 
|---|---|
| static MRJobStats | MRPigStatsUtil. addNativeJobStats(PigStats ps,
                 NativeMapReduceOper mr,
                 boolean success) | 
| static MRJobStats | MRPigStatsUtil. addNativeJobStats(PigStats ps,
                 NativeMapReduceOper mr,
                 boolean success,
                 java.lang.Exception e) | 
| Modifier and Type | Class and Description | 
|---|---|
| class  | SparkPigStats | 
| Modifier and Type | Method and Description | 
|---|---|
| java.util.Map<java.lang.String,java.util.List<PigStats>> | SparkPigStats. getAllStats() | 
| Modifier and Type | Method and Description | 
|---|---|
| static void | SparkStatsUtil. addFailedNativeJobStats(PigStats ps,
                       NativeSparkOperator nativeSparkOperator,
                       java.lang.Exception e) | 
| static void | SparkStatsUtil. addNativeJobStats(PigStats ps,
                 NativeSparkOperator nativeSparkOperator) | 
| Modifier and Type | Class and Description | 
|---|---|
| class  | TezPigScriptStats | 
| Modifier and Type | Method and Description | 
|---|---|
| java.util.Map<java.lang.String,java.util.List<PigStats>> | TezPigScriptStats. getAllStats() | 
Copyright © 2007-2025 The Apache Software Foundation