org.apache.flink.runtime.blocklist

Class DefaultBlocklistHandler.Factory

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 and Description
Factory(java.time.Duration timeoutCheckInterval)

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.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

Factory

public Factory(java.time.Duration timeoutCheckInterval)

Method Detail

create

public BlocklistHandler create(BlocklistContext blocklistContext,
                               java.util.function.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.