org.apache.flink.runtime.blocklist

Interface BlocklistListener

All Known Subinterfaces:

JobMasterGateway, ResourceManagerGateway

All Known Implementing Classes:

ActiveResourceManager, JobMaster, ResourceManager, StandaloneResourceManager

public interface BlocklistListener

A listener that want to be notified when blocklist changes.

Method Summary

Modifier and Type	Method and Description
CompletableFuture<Acknowledge>	notifyNewBlockedNodes(Collection<BlockedNode> newNodes) Notify new blocked node records.

Method Detail

notifyNewBlockedNodes

CompletableFuture<Acknowledge> notifyNewBlockedNodes(Collection<BlockedNode> newNodes)

Notify new blocked node records.

Parameters:

newNodes - the new blocked node records

Returns:

Future acknowledge once the new nodes have successfully notified.