Package | Description |
---|---|
org.apache.flink.mesos.runtime.clusterframework | |
org.apache.flink.mesos.util |
Constructor and Description |
---|
LaunchableMesosWorker(MesosArtifactResolver resolver,
MesosTaskManagerParameters params,
ContainerSpecification containerSpec,
org.apache.mesos.Protos.TaskID taskID,
MesosConfiguration mesosConfiguration)
Construct a launchable Mesos worker.
|
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 | Method and Description |
---|---|
static MesosConfiguration |
MesosUtils.createMesosSchedulerConfiguration(Configuration flinkConfig,
String hostname)
Loads and validates the Mesos scheduler configuration.
|
MesosConfiguration |
MesosConfiguration.withFrameworkInfo(org.apache.mesos.Protos.FrameworkInfo.Builder frameworkInfo)
Revise the configuration with updated framework info.
|
Modifier and Type | Method and Description |
---|---|
static void |
MesosConfiguration.logMesosConfig(org.slf4j.Logger log,
MesosConfiguration config)
A utility method to log relevant Mesos connection info.
|
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.