Package | Description |
---|---|
org.apache.flink.mesos.runtime.clusterframework | |
org.apache.flink.mesos.runtime.clusterframework.services | |
org.apache.flink.mesos.util |
Constructor and Description |
---|
MesosResourceManagerDriver(Configuration flinkConfig,
MesosServices mesosServices,
MesosConfiguration mesosConfig,
MesosTaskManagerParameters taskManagerParameters,
ContainerSpecification taskManagerContainerSpec,
String webUiUrl) |
MesosResourceManagerFactory(MesosServices mesosServices,
MesosConfiguration schedulerConfiguration) |
Modifier and Type | Method and Description |
---|---|
org.apache.mesos.SchedulerDriver |
AbstractMesosServices.createMesosSchedulerDriver(MesosConfiguration mesosConfig,
org.apache.mesos.Scheduler scheduler,
boolean implicitAcknowledgements) |
org.apache.mesos.SchedulerDriver |
MesosServices.createMesosSchedulerDriver(MesosConfiguration mesosConfig,
org.apache.mesos.Scheduler scheduler,
boolean implicitAcknowledgements)
Create the Mesos scheduler driver.
|
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.