Package | Description |
---|---|
org.apache.flink.mesos.runtime.clusterframework | |
org.apache.flink.mesos.runtime.clusterframework.services |
Constructor and Description |
---|
MesosResourceManager(RpcService rpcService,
String resourceManagerEndpointId,
ResourceID resourceId,
HighAvailabilityServices highAvailabilityServices,
HeartbeatServices heartbeatServices,
SlotManager slotManager,
MetricRegistry metricRegistry,
JobLeaderIdService jobLeaderIdService,
ClusterInformation clusterInformation,
FatalErrorHandler fatalErrorHandler,
Configuration flinkConfig,
MesosServices mesosServices,
MesosConfiguration mesosConfig,
MesosTaskManagerParameters taskManagerParameters,
ContainerSpecification taskManagerContainerSpec,
String webUiUrl,
JobManagerMetricGroup jobManagerMetricGroup) |
MesosResourceManagerFactory(MesosServices mesosServices,
MesosConfiguration schedulerConfiguration,
MesosTaskManagerParameters taskManagerParameters,
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(Configuration configuration,
String hostname)
Creates a
MesosServices instance depending on the high availability settings. |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.