public interface JobLeaderListener
JobLeaderService. The listener is notified whenever a job manager gained leadership for a registered job and the service could establish a connection to it. Furthermore, the listener is notified when a job manager loses leadership for a job. In case of an error, the
handleError(Throwable)} is called.
|Modifier and Type||Method and Description|
Callback for errors which might occur in the
Callback if a job manager has gained leadership for the job identified by the job id and a connection could be established to this job manager.
Callback if the job leader for the job with the given job id lost its leadership.
void jobManagerGainedLeadership(JobID jobId, JobMasterGateway jobManagerGateway, JMTMRegistrationSuccess registrationMessage)
jobId- identifying the job for which the job manager has gained leadership
jobManagerGateway- to the job leader
registrationMessage- containing further registration information
void jobManagerLostLeadership(JobID jobId, JobMasterId jobMasterId)
jobId- identifying the job whose leader has lost leadership
jobMasterId- old JobMasterId
void handleError(Throwable throwable)
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.