org.apache.flink.runtime.blocklist

Interface BlocklistContext

public interface BlocklistContext

This class is responsible for blocking and unblocking resources.

Method Summary

Modifier and Type	Method and Description
void	blockResources(Collection<BlockedNode> blockedNodes) Block resources on the nodes.
void	unblockResources(Collection<BlockedNode> unblockedNodes) Unblock resources on the nodes.

Method Detail

blockResources

void blockResources(Collection<BlockedNode> blockedNodes)

Block resources on the nodes.

Parameters:

blockedNodes - the nodes to block resources

unblockResources

void unblockResources(Collection<BlockedNode> unblockedNodes)

Unblock resources on the nodes.

Parameters:

unblockedNodes - the nodes to unblock resources