| Package | Description |
|---|---|
| org.apache.flink.mesos.runtime.clusterframework | |
| org.apache.flink.mesos.runtime.clusterframework.services |
| Constructor and Description |
|---|
MesosResourceManager(org.apache.flink.runtime.rpc.RpcService rpcService,
String resourceManagerEndpointId,
org.apache.flink.runtime.clusterframework.types.ResourceID resourceId,
org.apache.flink.runtime.highavailability.HighAvailabilityServices highAvailabilityServices,
org.apache.flink.runtime.heartbeat.HeartbeatServices heartbeatServices,
org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager slotManager,
org.apache.flink.runtime.metrics.MetricRegistry metricRegistry,
org.apache.flink.runtime.resourcemanager.JobLeaderIdService jobLeaderIdService,
org.apache.flink.runtime.entrypoint.ClusterInformation clusterInformation,
org.apache.flink.runtime.rpc.FatalErrorHandler fatalErrorHandler,
org.apache.flink.configuration.Configuration flinkConfig,
MesosServices mesosServices,
MesosConfiguration mesosConfig,
MesosTaskManagerParameters taskManagerParameters,
org.apache.flink.runtime.clusterframework.ContainerSpecification taskManagerContainerSpec,
String webUiUrl,
org.apache.flink.runtime.metrics.groups.JobManagerMetricGroup jobManagerMetricGroup) |
MesosResourceManagerFactory(MesosServices mesosServices,
MesosConfiguration schedulerConfiguration,
MesosTaskManagerParameters taskManagerParameters,
org.apache.flink.runtime.clusterframework.ContainerSpecification taskManagerContainerSpec) |
| Modifier and Type | Class and Description |
|---|---|
class |
AbstractMesosServices
An abstract implementation of
MesosServices. |
class |
StandaloneMesosServices
MesosServices implementation for the standalone mode. |
class |
ZooKeeperMesosServices
MesosServices implementation for the ZooKeeper high availability based mode. |
| Modifier and Type | Method and Description |
|---|---|
static MesosServices |
MesosServicesUtils.createMesosServices(org.apache.flink.configuration.Configuration configuration,
String hostname)
Creates a
MesosServices instance depending on the high availability settings. |
Copyright © 2014–2019 The Apache Software Foundation. All rights reserved.