org.apache.flink.mesos.runtime.clusterframework

Class MesosResourceManagerFactory

java.lang.Object

org.apache.flink.mesos.runtime.clusterframework.MesosResourceManagerFactory

All Implemented Interfaces:

ResourceManagerFactory<RegisteredMesosWorkerNode>

public class MesosResourceManagerFactory
extends Object
implements ResourceManagerFactory<RegisteredMesosWorkerNode>

ResourceManagerFactory which creates a MesosResourceManager.

Constructor Summary

Constructors

Constructor and Description
MesosResourceManagerFactory(MesosServices mesosServices, MesosConfiguration schedulerConfiguration, MesosTaskManagerParameters taskManagerParameters, ContainerSpecification taskManagerContainerSpec)

Method Summary

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

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.ResourceManagerFactory

generateEndpointIdWithUUID, getEndpointId

Constructor Detail

MesosResourceManagerFactory

public MesosResourceManagerFactory(@Nonnull
                                   MesosServices mesosServices,
                                   @Nonnull
                                   MesosConfiguration schedulerConfiguration,
                                   @Nonnull
                                   MesosTaskManagerParameters taskManagerParameters,
                                   @Nonnull
                                   ContainerSpecification taskManagerContainerSpec)

Method Detail

createResourceManager

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

Specified by:

createResourceManager in interface ResourceManagerFactory<RegisteredMesosWorkerNode>

Throws:

Exception