org.apache.flink.mesos.runtime.clusterframework

Class MesosResourceManagerFactory

java.lang.Object

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

All Implemented Interfaces:

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

public class MesosResourceManagerFactory
extends Object
implements org.apache.flink.runtime.resourcemanager.ResourceManagerFactory<RegisteredMesosWorkerNode>

ResourceManagerFactory which creates a MesosResourceManager.

Constructor Summary

Constructors

Constructor and Description
MesosResourceManagerFactory(MesosServices mesosServices, MesosConfiguration schedulerConfiguration, MesosTaskManagerParameters taskManagerParameters, org.apache.flink.runtime.clusterframework.ContainerSpecification taskManagerContainerSpec)

Method Summary

Modifier and Type

Method and Description

org.apache.flink.runtime.resourcemanager.ResourceManager<RegisteredMesosWorkerNode>

createResourceManager(org.apache.flink.configuration.Configuration configuration, org.apache.flink.runtime.clusterframework.types.ResourceID resourceId, org.apache.flink.runtime.rpc.RpcService rpcService, org.apache.flink.runtime.highavailability.HighAvailabilityServices highAvailabilityServices, org.apache.flink.runtime.heartbeat.HeartbeatServices heartbeatServices, org.apache.flink.runtime.metrics.MetricRegistry metricRegistry, org.apache.flink.runtime.rpc.FatalErrorHandler fatalErrorHandler, org.apache.flink.runtime.entrypoint.ClusterInformation clusterInformation, String webInterfaceUrl, org.apache.flink.runtime.metrics.groups.JobManagerMetricGroup jobManagerMetricGroup)

Methods inherited from class java.lang.Object

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

Constructor Detail

MesosResourceManagerFactory

public MesosResourceManagerFactory(@Nonnull
                                   MesosServices mesosServices,
                                   @Nonnull
                                   MesosConfiguration schedulerConfiguration,
                                   @Nonnull
                                   MesosTaskManagerParameters taskManagerParameters,
                                   @Nonnull
                                   org.apache.flink.runtime.clusterframework.ContainerSpecification taskManagerContainerSpec)

Method Detail

createResourceManager

public org.apache.flink.runtime.resourcemanager.ResourceManager<RegisteredMesosWorkerNode> createResourceManager(org.apache.flink.configuration.Configuration configuration,
                                                                                                                 org.apache.flink.runtime.clusterframework.types.ResourceID resourceId,
                                                                                                                 org.apache.flink.runtime.rpc.RpcService rpcService,
                                                                                                                 org.apache.flink.runtime.highavailability.HighAvailabilityServices highAvailabilityServices,
                                                                                                                 org.apache.flink.runtime.heartbeat.HeartbeatServices heartbeatServices,
                                                                                                                 org.apache.flink.runtime.metrics.MetricRegistry metricRegistry,
                                                                                                                 org.apache.flink.runtime.rpc.FatalErrorHandler fatalErrorHandler,
                                                                                                                 org.apache.flink.runtime.entrypoint.ClusterInformation clusterInformation,
                                                                                                                 @Nullable
                                                                                                                 String webInterfaceUrl,
                                                                                                                 org.apache.flink.runtime.metrics.groups.JobManagerMetricGroup jobManagerMetricGroup)
                                                                                                          throws Exception

Specified by:

createResourceManager in interface org.apache.flink.runtime.resourcemanager.ResourceManagerFactory<RegisteredMesosWorkerNode>

Throws:

Exception