Changed Methods |
void jobFailedNotification(String, JobStats)
|
Change in signature from JobStats to (String, JobStats ).
|
Invoked when a MR job fails. |
void jobFinishedNotification(String, JobStats)
|
Change in signature from JobStats to (String, JobStats ).
|
Invoked just after a MR job is completed successfully. |
void jobStartedNotification(String, String)
|
Change in signature from String to (String, String ).
|
Invoked after a MR job is started. |
void jobsSubmittedNotification(String, int)
|
Change in signature from int to (String, int ).
|
Invoked just before submitting a batch of MR jobs. |
void launchCompletedNotification(String, int)
|
Change in signature from int to (String, int ).
|
Invoked just after all MR jobs spawned by the script are completed. |
void launchStartedNotification(String, int)
|
Change in signature from int to (String, int ).
|
Invoked just before launching MR jobs spawned by the script. |
void outputCompletedNotification(String, OutputStats)
|
Change in signature from OutputStats to (String, OutputStats ).
|
Invoked just after an output is successfully written. |
void progressUpdatedNotification(String, int)
|
Change in signature from int to (String, int ).
|
Invoked to update the execution progress. |