Class NoOpBlocklistHandler.Factory
- java.lang.Object
-
- org.apache.flink.runtime.blocklist.NoOpBlocklistHandler.Factory
-
- All Implemented Interfaces:
BlocklistHandler.Factory
- Enclosing class:
- NoOpBlocklistHandler
public static class NoOpBlocklistHandler.Factory extends Object implements BlocklistHandler.Factory
The factory to instantiateNoOpBlocklistHandler
.
-
-
Constructor Summary
Constructors Constructor Description Factory()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description BlocklistHandler
create(BlocklistContext blocklistContext, Function<ResourceID,String> taskManagerNodeIdRetriever, ComponentMainThreadExecutor mainThreadExecutor, org.slf4j.Logger log)
Instantiates aBlocklistHandler
.
-
-
-
Method Detail
-
create
public BlocklistHandler create(BlocklistContext blocklistContext, Function<ResourceID,String> taskManagerNodeIdRetriever, ComponentMainThreadExecutor mainThreadExecutor, org.slf4j.Logger log)
Description copied from interface:BlocklistHandler.Factory
Instantiates aBlocklistHandler
.- Specified by:
create
in interfaceBlocklistHandler.Factory
- Parameters:
blocklistContext
- the blocklist contexttaskManagerNodeIdRetriever
- to map a task manager to the node it's located onmainThreadExecutor
- to schedule the timeout checklog
- the logger- Returns:
- an instantiated blocklist handler.
-
-