Package org.apache.flink.runtime.resourcemanager

Class ResourceManagerFactory<T extends ResourceIDRetrievable>

java.lang.Object

org.apache.flink.runtime.resourcemanager.ResourceManagerFactory<T>

Type Parameters:

T - type of the workers of the ResourceManager

Direct Known Subclasses:

ActiveResourceManagerFactory, StandaloneResourceManagerFactory

public abstract class ResourceManagerFactory<T extends ResourceIDRetrievable>
extends Object

ResourceManager factory.

Field Summary

Fields

Modifier and Type	Field	Description
protected org.slf4j.Logger	log

Constructor Summary

Constructors

Constructor	Description
ResourceManagerFactory()

Method Summary

Modifier and Type	Method	Description
protected abstract ResourceManager<T>	createResourceManager(org.apache.flink.configuration.Configuration configuration, ResourceID resourceId, org.apache.flink.runtime.rpc.RpcService rpcService, UUID leaderSessionId, HeartbeatServices heartbeatServices, DelegationTokenManager delegationTokenManager, org.apache.flink.runtime.rpc.FatalErrorHandler fatalErrorHandler, ClusterInformation clusterInformation, String webInterfaceUrl, ResourceManagerMetricGroup resourceManagerMetricGroup, ResourceManagerRuntimeServices resourceManagerRuntimeServices, Executor ioExecutor)
ResourceManager<T>	createResourceManager(ResourceManagerProcessContext context, UUID leaderSessionId)
ResourceManagerProcessContext	createResourceManagerProcessContext(org.apache.flink.configuration.Configuration configuration, ResourceID resourceId, org.apache.flink.runtime.rpc.RpcService rpcService, HighAvailabilityServices highAvailabilityServices, HeartbeatServices heartbeatServices, DelegationTokenManager delegationTokenManager, org.apache.flink.runtime.rpc.FatalErrorHandler fatalErrorHandler, ClusterInformation clusterInformation, String webInterfaceUrl, MetricRegistry metricRegistry, String hostname, Executor ioExecutor)
protected abstract ResourceManagerRuntimeServicesConfiguration	createResourceManagerRuntimeServicesConfiguration(org.apache.flink.configuration.Configuration configuration)
protected org.apache.flink.configuration.Configuration	getEffectiveConfigurationForResourceManager(org.apache.flink.configuration.Configuration configuration)	Configuration changes in this method will be visible to only ResourceManager.
protected org.apache.flink.configuration.Configuration	getEffectiveConfigurationForResourceManagerAndRuntimeServices(org.apache.flink.configuration.Configuration configuration)	Configuration changes in this method will be visible to both ResourceManager and ResourceManagerRuntimeServices.
protected boolean	supportMultiLeaderSession()	This indicates whether the process should be terminated after losing leadership.

Methods inherited from class java.lang.Object

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

Field Detail

log

protected final org.slf4j.Logger log

Constructor Detail

ResourceManagerFactory

public ResourceManagerFactory()

Method Detail

createResourceManagerProcessContext

public ResourceManagerProcessContext createResourceManagerProcessContext(org.apache.flink.configuration.Configuration configuration,
                                                                         ResourceID resourceId,
                                                                         org.apache.flink.runtime.rpc.RpcService rpcService,
                                                                         HighAvailabilityServices highAvailabilityServices,
                                                                         HeartbeatServices heartbeatServices,
                                                                         DelegationTokenManager delegationTokenManager,
                                                                         org.apache.flink.runtime.rpc.FatalErrorHandler fatalErrorHandler,
                                                                         ClusterInformation clusterInformation,
                                                                         @Nullable
                                                                         String webInterfaceUrl,
                                                                         MetricRegistry metricRegistry,
                                                                         String hostname,
                                                                         Executor ioExecutor)
                                                                  throws org.apache.flink.util.ConfigurationException

Throws:

org.apache.flink.util.ConfigurationException

createResourceManager

public ResourceManager<T> createResourceManager(ResourceManagerProcessContext context,
                                                UUID leaderSessionId)
                                         throws Exception

Throws:

Exception

supportMultiLeaderSession

protected boolean supportMultiLeaderSession()

This indicates whether the process should be terminated after losing leadership.

getEffectiveConfigurationForResourceManagerAndRuntimeServices

protected org.apache.flink.configuration.Configuration getEffectiveConfigurationForResourceManagerAndRuntimeServices(org.apache.flink.configuration.Configuration configuration)

Configuration changes in this method will be visible to both ResourceManager and ResourceManagerRuntimeServices. This can be overwritten by getEffectiveConfigurationForResourceManager(org.apache.flink.configuration.Configuration).

getEffectiveConfigurationForResourceManager

protected org.apache.flink.configuration.Configuration getEffectiveConfigurationForResourceManager(org.apache.flink.configuration.Configuration configuration)

Configuration changes in this method will be visible to only ResourceManager. This can overwrite getEffectiveConfigurationForResourceManagerAndRuntimeServices(org.apache.flink.configuration.Configuration).

createResourceManager

protected abstract ResourceManager<T> createResourceManager(org.apache.flink.configuration.Configuration configuration,
                                                            ResourceID resourceId,
                                                            org.apache.flink.runtime.rpc.RpcService rpcService,
                                                            UUID leaderSessionId,
                                                            HeartbeatServices heartbeatServices,
                                                            DelegationTokenManager delegationTokenManager,
                                                            org.apache.flink.runtime.rpc.FatalErrorHandler fatalErrorHandler,
                                                            ClusterInformation clusterInformation,
                                                            @Nullable
                                                            String webInterfaceUrl,
                                                            ResourceManagerMetricGroup resourceManagerMetricGroup,
                                                            ResourceManagerRuntimeServices resourceManagerRuntimeServices,
                                                            Executor ioExecutor)
                                                     throws Exception

Throws:

Exception

createResourceManagerRuntimeServicesConfiguration

protected abstract ResourceManagerRuntimeServicesConfiguration createResourceManagerRuntimeServicesConfiguration(org.apache.flink.configuration.Configuration configuration)
                                                                                                          throws org.apache.flink.util.ConfigurationException

Throws:

org.apache.flink.util.ConfigurationException