org.apache.flink.runtime.resourcemanager.active

Class AbstractResourceManagerDriver<WorkerType extends ResourceIDRetrievable>

java.lang.Object

org.apache.flink.runtime.resourcemanager.active.AbstractResourceManagerDriver<WorkerType>

All Implemented Interfaces:

ResourceManagerDriver<WorkerType>

Direct Known Subclasses:

KubernetesResourceManagerDriver, YarnResourceManagerDriver

public abstract class AbstractResourceManagerDriver<WorkerType extends ResourceIDRetrievable>
extends Object
implements ResourceManagerDriver<WorkerType>

Abstract common base class for implementations of ResourceManagerDriver.

Field Summary

Fields

Modifier and Type	Field and Description
protected Configuration	flinkClientConfig
protected Configuration	flinkConfig
protected org.slf4j.Logger	log

Constructor Summary

Constructors

Constructor and Description
AbstractResourceManagerDriver(Configuration flinkConfig, Configuration flinkClientConfig)

Method Summary

Modifier and Type	Method and Description
protected BlockedNodeRetriever	getBlockedNodeRetriever()
protected Executor	getIoExecutor()
protected ScheduledExecutor	getMainThreadExecutor()
protected ResourceEventHandler<WorkerType>	getResourceEventHandler()
void	initialize(ResourceEventHandler<WorkerType> resourceEventHandler, ScheduledExecutor mainThreadExecutor, Executor ioExecutor, BlockedNodeRetriever blockedNodeRetriever) Initialize the deployment specific components.
protected abstract void	initializeInternal() Initialize the deployment specific components.

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.flink.runtime.resourcemanager.active.ResourceManagerDriver

deregisterApplication, releaseResource, requestResource, terminate

Field Detail

log

protected final org.slf4j.Logger log

flinkConfig

protected final Configuration flinkConfig

flinkClientConfig

protected final Configuration flinkClientConfig

Constructor Detail

AbstractResourceManagerDriver

public AbstractResourceManagerDriver(Configuration flinkConfig,
                                     Configuration flinkClientConfig)

Method Detail

getResourceEventHandler

protected final ResourceEventHandler<WorkerType> getResourceEventHandler()

getMainThreadExecutor

protected final ScheduledExecutor getMainThreadExecutor()

getIoExecutor

protected final Executor getIoExecutor()

getBlockedNodeRetriever

protected final BlockedNodeRetriever getBlockedNodeRetriever()

initialize

public final void initialize(ResourceEventHandler<WorkerType> resourceEventHandler,
                             ScheduledExecutor mainThreadExecutor,
                             Executor ioExecutor,
                             BlockedNodeRetriever blockedNodeRetriever)
                      throws Exception

Description copied from interface: ResourceManagerDriver

Initialize the deployment specific components.

Specified by:

initialize in interface ResourceManagerDriver<WorkerType extends ResourceIDRetrievable>

Parameters:

resourceEventHandler - Handler that handles resource events.

mainThreadExecutor - Rpc main thread executor.

ioExecutor - IO executor.

blockedNodeRetriever - To retrieve all blocked nodes

Throws:

Exception

initializeInternal

protected abstract void initializeInternal()
                                    throws Exception

Initialize the deployment specific components.

Throws:

Exception