DefaultBlocklistHandler.Factory (Flink : 2.0-SNAPSHOT API)

java.lang.Object
- org.apache.flink.runtime.blocklist.DefaultBlocklistHandler.Factory

All Implemented Interfaces:

BlocklistHandler.Factory

Enclosing class:

DefaultBlocklistHandler
```
public static class DefaultBlocklistHandler.Factory
extends Object
implements BlocklistHandler.Factory
```
The factory to instantiate DefaultBlocklistHandler.

Constructor Summary

Constructors
Constructor Description

Factory(Duration timeoutCheckInterval)

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 a `BlocklistHandler`.

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- Constructor Detail
  - Factory
```
public Factory(Duration timeoutCheckInterval)
```
- 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 a BlocklistHandler.
    
    Specified by:
    
    create in interface BlocklistHandler.Factory
    
    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.