public class DefaultBlocklistTracker extends Object implements BlocklistTracker
BlocklistTracker
.Constructor and Description |
---|
DefaultBlocklistTracker() |
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 currentTimestamp)
Remove timeout nodes.
|
public org.apache.flink.runtime.blocklist.BlockedNodeAdditionResult addNewBlockedNodes(Collection<BlockedNode> newNodes)
BlocklistTracker
addNewBlockedNodes
in interface BlocklistTracker
newNodes
- the new blocked node recordspublic boolean isBlockedNode(String nodeId)
BlocklistTracker
isBlockedNode
in interface BlocklistTracker
nodeId
- ID of the node to querypublic Set<String> getAllBlockedNodeIds()
BlocklistTracker
getAllBlockedNodeIds
in interface BlocklistTracker
public Collection<BlockedNode> getAllBlockedNodes()
BlocklistTracker
getAllBlockedNodes
in interface BlocklistTracker
public Collection<BlockedNode> removeTimeoutNodes(long currentTimestamp)
BlocklistTracker
removeTimeoutNodes
in interface BlocklistTracker
currentTimestamp
- current timeCopyright © 2014–2023 The Apache Software Foundation. All rights reserved.