@InterfaceAudience.Public @InterfaceStability.Evolving public interface PigProgressNotificationListener extends EventListener
PigRunner
.Modifier and Type | Method and Description |
---|---|
void |
initialPlanNotification(String scriptId,
OperatorPlan<?> plan)
Invoked before any Hadoop jobs (or a Tez DAG) are run with the plan that is to be executed.
|
void |
jobFailedNotification(String scriptId,
JobStats jobStats)
Invoked when a Hadoop job fails.
|
void |
jobFinishedNotification(String scriptId,
JobStats jobStats)
Invoked just after a Hadoop job (or Tez DAG) is completed successfully.
|
void |
jobsSubmittedNotification(String scriptId,
int numJobsSubmitted)
Invoked just before submitting a batch of Hadoop jobs (or Tez DAGs).
|
void |
jobStartedNotification(String scriptId,
String assignedJobId)
Invoked after a Hadoop job (or Tez DAG) is started.
|
void |
launchCompletedNotification(String scriptId,
int numJobsSucceeded)
Invoked just after all Hadoop jobs (Tez DAGs) spawned by the script are completed.
|
void |
launchStartedNotification(String scriptId,
int numJobsToLaunch)
Invoked just before launching Hadoop jobs (or tez DAGs) spawned by the script.
|
void |
outputCompletedNotification(String scriptId,
OutputStats outputStats)
Invoked just after an output is successfully written.
|
void |
progressUpdatedNotification(String scriptId,
int progress)
Invoked to update the execution progress.
|
void initialPlanNotification(String scriptId, OperatorPlan<?> plan)
scriptId
- the unique id of the scriptplan
- the OperatorPlan that is to be executedvoid launchStartedNotification(String scriptId, int numJobsToLaunch)
scriptId
- the unique id of the scriptnumJobsToLaunch
- the total number of Hadoop jobs (or Tez DAGs) spawned by the scriptvoid jobsSubmittedNotification(String scriptId, int numJobsSubmitted)
scriptId
- the unique id of the scriptnumJobsSubmitted
- the number of Hadoop jobs (or Tez DAGs) in the batchvoid jobStartedNotification(String scriptId, String assignedJobId)
scriptId
- the unique id of the scriptassignedJobId
- the Hadoop job id (or Tez DAG job id)void jobFinishedNotification(String scriptId, JobStats jobStats)
scriptId
- the unique id of the scriptjobStats
- the JobStats
object associated with the Hadoop job (or Tez DAG)void jobFailedNotification(String scriptId, JobStats jobStats)
scriptId
- the unique id of the scriptjobStats
- the JobStats
object associated with the Hadoop jobvoid outputCompletedNotification(String scriptId, OutputStats outputStats)
scriptId
- the unique id of the scriptoutputStats
- the OutputStats
object associated with the outputvoid progressUpdatedNotification(String scriptId, int progress)
scriptId
- the unique id of the scriptprogress
- the percentage of the execution progressvoid launchCompletedNotification(String scriptId, int numJobsSucceeded)
scriptId
- the unique id of the scriptnumJobsSucceeded
- the total number of Hadoop jobs (Tez DAGs) succeededCopyright © 2007-2017 The Apache Software Foundation