org.apache.flink.runtime.blocklist

Interface BlocklistTracker

All Known Implementing Classes:

DefaultBlocklistTracker

public interface BlocklistTracker

A tracker for blocklist.

Method Summary

Modifier and Type	Method and Description
org.apache.flink.runtime.blocklist.BlockedNodeAdditionResult	addNewBlockedNodes(Collection<BlockedNode> newNodes) Add new blocked node records.
Set<String>	getAllBlockedNodeIds() Get all blocked node ids.
Collection<BlockedNode>	getAllBlockedNodes() Get all blocked nodes.
boolean	isBlockedNode(String nodeId) Returns whether the given node is blocked.
Collection<BlockedNode>	removeTimeoutNodes(long currentTimeMillis) Remove timeout nodes.

Method Detail

addNewBlockedNodes

org.apache.flink.runtime.blocklist.BlockedNodeAdditionResult addNewBlockedNodes(Collection<BlockedNode> newNodes)

Add new blocked node records. If a node (identified by node id) already exists, the newly added one will be merged with the existing one.

Parameters:

newNodes - the new blocked node records

Returns:

the addition result

isBlockedNode

boolean isBlockedNode(String nodeId)

Returns whether the given node is blocked.

Parameters:

nodeId - ID of the node to query

Returns:

true if the given node is blocked, otherwise false

getAllBlockedNodeIds

Set<String> getAllBlockedNodeIds()

Get all blocked node ids.

Returns:

a set containing all blocked node ids

getAllBlockedNodes

Collection<BlockedNode> getAllBlockedNodes()

Get all blocked nodes.

Returns:

a collection containing all blocked nodes

removeTimeoutNodes

Collection<BlockedNode> removeTimeoutNodes(long currentTimeMillis)

Remove timeout nodes.

Parameters:

currentTimeMillis - current time

Returns:

the removed nodes