org.apache.flink.runtime.blocklist

Interface BlocklistHandler.Factory

All Known Implementing Classes:

DefaultBlocklistHandler.Factory, NoOpBlocklistHandler.Factory

Enclosing interface:

BlocklistHandler

public static interface BlocklistHandler.Factory

Factory to instantiate BlocklistHandler.

Method Summary

Modifier and Type	Method and Description
BlocklistHandler	create(BlocklistContext blocklistContext, java.util.function.Function<ResourceID,String> taskManagerNodeIdRetriever, ComponentMainThreadExecutor mainThreadExecutor, org.slf4j.Logger log) Instantiates a BlocklistHandler.

Method Detail

create

BlocklistHandler create(BlocklistContext blocklistContext,
                        java.util.function.Function<ResourceID,String> taskManagerNodeIdRetriever,
                        ComponentMainThreadExecutor mainThreadExecutor,
                        org.slf4j.Logger log)

Instantiates a BlocklistHandler.

Parameters:

blocklistContext - the blocklist context

taskManagerNodeIdRetriever - to map a task manager to the node it's located on

mainThreadExecutor - to schedule the timeout check

log - the logger

Returns:

an instantiated blocklist handler.