org.apache.flink.runtime.minicluster

Class OneTimeLeaderListenerFuture

java.lang.Object

org.apache.flink.runtime.minicluster.OneTimeLeaderListenerFuture

All Implemented Interfaces:

LeaderRetrievalListener

public class OneTimeLeaderListenerFuture
extends Object
implements LeaderRetrievalListener

A leader listener that exposes a future for the first leader notification.

The future can be obtained via the future() method.

Constructor Summary

Constructors

Constructor and Description
OneTimeLeaderListenerFuture()

Method Summary

Modifier and Type	Method and Description
CompletableFuture<LeaderAddressAndId>	future() Gets the future that is completed with the leader address and ID.
void	handleError(Exception exception) This method is called by the LeaderRetrievalService in case of an exception.
void	notifyLeaderAddress(String leaderAddress, UUID leaderSessionID) This method is called by the LeaderRetrievalService when a new leader is elected.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

OneTimeLeaderListenerFuture

public OneTimeLeaderListenerFuture()

Method Detail

future

public CompletableFuture<LeaderAddressAndId> future()

Gets the future that is completed with the leader address and ID.

Returns:

The future.

notifyLeaderAddress

public void notifyLeaderAddress(String leaderAddress,
                                UUID leaderSessionID)

Description copied from interface: LeaderRetrievalListener

This method is called by the LeaderRetrievalService when a new leader is elected.

Specified by:

notifyLeaderAddress in interface LeaderRetrievalListener

Parameters:

leaderAddress - The address of the new leader

leaderSessionID - The new leader session ID

handleError

public void handleError(Exception exception)

Description copied from interface: LeaderRetrievalListener

This method is called by the LeaderRetrievalService in case of an exception. This assures that the LeaderRetrievalListener is aware of any problems occurring in the LeaderRetrievalService thread.

Specified by:

handleError in interface LeaderRetrievalListener