org.apache.flink.runtime.resourcemanager

Class ActiveResourceManagerFactory<T extends ResourceIDRetrievable>

java.lang.Object

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

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

Type Parameters:

T - type of the ResourceIDRetrievable

Direct Known Subclasses:

KubernetesResourceManagerFactory, MesosResourceManagerFactory, YarnResourceManagerFactory

public abstract class ActiveResourceManagerFactory<T extends ResourceIDRetrievable>
extends ResourceManagerFactory<T>

Resource manager factory which creates active ResourceManager implementations.

The default implementation will call createActiveResourceManagerConfiguration(org.apache.flink.configuration.Configuration) to create a new configuration which is configured with active resource manager relevant configuration options.

Constructor Summary

Constructors

Constructor and Description
ActiveResourceManagerFactory()

Method Summary

Modifier and Type	Method and Description
ResourceManager<T>	createResourceManager(Configuration configuration, ResourceID resourceId, RpcService rpcService, HighAvailabilityServices highAvailabilityServices, HeartbeatServices heartbeatServices, FatalErrorHandler fatalErrorHandler, ClusterInformation clusterInformation, String webInterfaceUrl, MetricRegistry metricRegistry, String hostname)

Methods inherited from class org.apache.flink.runtime.resourcemanager.ResourceManagerFactory

createResourceManager, createResourceManagerRuntimeServicesConfiguration

Methods inherited from class java.lang.Object

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

Constructor Detail

ActiveResourceManagerFactory

public ActiveResourceManagerFactory()

Method Detail

createResourceManager

public ResourceManager<T> createResourceManager(Configuration configuration,
                                                ResourceID resourceId,
                                                RpcService rpcService,
                                                HighAvailabilityServices highAvailabilityServices,
                                                HeartbeatServices heartbeatServices,
                                                FatalErrorHandler fatalErrorHandler,
                                                ClusterInformation clusterInformation,
                                                @Nullable
                                                String webInterfaceUrl,
                                                MetricRegistry metricRegistry,
                                                String hostname)
                                         throws Exception

Overrides:

createResourceManager in class ResourceManagerFactory<T extends ResourceIDRetrievable>

Throws:

Exception