Package | Description |
---|---|
org.apache.flink.mesos.runtime.clusterframework | |
org.apache.flink.mesos.runtime.clusterframework.services |
Constructor and Description |
---|
MesosResourceManager(RpcService rpcService,
ResourceID resourceId,
HighAvailabilityServices highAvailabilityServices,
HeartbeatServices heartbeatServices,
SlotManager slotManager,
ResourceManagerPartitionTrackerFactory clusterPartitionTrackerFactory,
JobLeaderIdService jobLeaderIdService,
ClusterInformation clusterInformation,
FatalErrorHandler fatalErrorHandler,
Configuration flinkConfig,
MesosServices mesosServices,
MesosConfiguration mesosConfig,
MesosTaskManagerParameters taskManagerParameters,
ContainerSpecification taskManagerContainerSpec,
String webUiUrl,
ResourceManagerMetricGroup resourceManagerMetricGroup) |
MesosResourceManagerFactory(MesosServices mesosServices,
MesosConfiguration schedulerConfiguration) |
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–2021 The Apache Software Foundation. All rights reserved.