org.apache.flink.runtime.blocklist

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 instantiate NoOpBlocklistHandler.

Constructor Summary

Constructors

Constructor and Description
Factory()

Method Summary

Modifier and Type	Method and 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()

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.