Package org.apache.flink.runtime.blocklist

Interface BlocklistTracker

  • All Known Implementing Classes:
    DefaultBlocklistTracker
    public interface BlocklistTracker
    A tracker for blocklist.

    • 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