org.apache.flink.runtime.leaderelection

Interface LeaderContender

All Known Implementing Classes:

Dispatcher, DispatcherRestEndpoint, JobManagerRunner, MesosResourceManager, MiniDispatcher, MiniDispatcherRestEndpoint, ResourceManager, StandaloneDispatcher, StandaloneResourceManager, WebMonitorEndpoint, YarnResourceManager

public interface LeaderContender

Interface which has to be implemented to take part in the leader election process of the LeaderElectionService.

Method Summary

Modifier and Type	Method and Description
String	getAddress() Returns the address of the LeaderContender under which other instances can connect to it.
void	grantLeadership(UUID leaderSessionID) Callback method which is called by the LeaderElectionService upon selecting this instance as the new leader.
void	handleError(Exception exception) Callback method which is called by LeaderElectionService in case of an error in the service thread.
void	revokeLeadership() Callback method which is called by the LeaderElectionService upon revoking the leadership of a former leader.

Method Detail

grantLeadership

void grantLeadership(UUID leaderSessionID)

Callback method which is called by the LeaderElectionService upon selecting this instance as the new leader. The method is called with the new leader session ID.

Parameters:

leaderSessionID - New leader session ID

revokeLeadership

void revokeLeadership()

Callback method which is called by the LeaderElectionService upon revoking the leadership of a former leader. This might happen in case that multiple contenders have been granted leadership.

getAddress

String getAddress()

Returns the address of the LeaderContender under which other instances can connect to it.

Returns:

Address of this contender.

handleError

void handleError(Exception exception)

Callback method which is called by LeaderElectionService in case of an error in the service thread.

Parameters:

exception - Caught exception