|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
@InterfaceAudience.Public @InterfaceStability.Evolving public interface PigProgressNotificationListener
Should be implemented by an object that wants to receive notifications
from PigRunner
.
Method Summary | |
---|---|
void |
jobFailedNotification(String scriptId,
JobStats jobStats)
Invoked when a MR job fails. |
void |
jobFinishedNotification(String scriptId,
JobStats jobStats)
Invoked just after a MR job is completed successfully. |
void |
jobsSubmittedNotification(String scriptId,
int numJobsSubmitted)
Invoked just before submitting a batch of MR jobs. |
void |
jobStartedNotification(String scriptId,
String assignedJobId)
Invoked after a MR job is started. |
void |
launchCompletedNotification(String scriptId,
int numJobsSucceeded)
Invoked just after all MR jobs spawned by the script are completed. |
void |
launchStartedNotification(String scriptId,
int numJobsToLaunch)
Invoked just before launching MR jobs 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. |
Method Detail |
---|
void launchStartedNotification(String scriptId, int numJobsToLaunch)
scriptId
- the unique id of the scriptnumJobsToLaunch
- the total number of MR jobs spawned by the scriptvoid jobsSubmittedNotification(String scriptId, int numJobsSubmitted)
scriptId
- the unique id of the scriptnumJobsSubmitted
- the number of MR jobs in the batchvoid jobStartedNotification(String scriptId, String assignedJobId)
scriptId
- the unique id of the scriptassignedJobId
- the MR job idvoid jobFinishedNotification(String scriptId, JobStats jobStats)
scriptId
- the unique id of the scriptjobStats
- the JobStats
object associated with the MR jobvoid jobFailedNotification(String scriptId, JobStats jobStats)
scriptId
- the unique id of the scriptjobStats
- the JobStats
object associated with the MR 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 MR jobs succeeded
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |