Uses of Class
org.apache.flink.mesos.util.MesosConfiguration

Packages that use MesosConfiguration

Package	Description
org.apache.flink.mesos.entrypoint
org.apache.flink.mesos.runtime.clusterframework
org.apache.flink.mesos.util

Uses of MesosConfiguration in org.apache.flink.mesos.entrypoint

Methods in org.apache.flink.mesos.entrypoint that return MesosConfiguration

Modifier and Type	Method and Description
static MesosConfiguration	MesosEntrypointUtils.createMesosSchedulerConfiguration(org.apache.flink.configuration.Configuration flinkConfig, String hostname) Loads and validates the Mesos scheduler configuration.

Uses of MesosConfiguration in org.apache.flink.mesos.runtime.clusterframework

Methods in org.apache.flink.mesos.runtime.clusterframework with parameters of type MesosConfiguration

Modifier and Type

Method and Description

static akka.actor.Props

MesosFlinkResourceManager.createActorProps(Class<? extends MesosFlinkResourceManager> actorClass, org.apache.flink.configuration.Configuration flinkConfig, MesosConfiguration mesosConfig, MesosWorkerStore workerStore, org.apache.flink.runtime.leaderretrieval.LeaderRetrievalService leaderRetrievalService, MesosTaskManagerParameters taskManagerParameters, org.apache.flink.runtime.clusterframework.ContainerSpecification taskManagerContainerSpec, MesosArtifactResolver artifactResolver, org.slf4j.Logger log) Creates the props needed to instantiate this actor.

Constructors in org.apache.flink.mesos.runtime.clusterframework with parameters of type MesosConfiguration

Constructor and Description
LaunchableMesosWorker(MesosArtifactResolver resolver, MesosTaskManagerParameters params, org.apache.flink.runtime.clusterframework.ContainerSpecification containerSpec, org.apache.mesos.Protos.TaskID taskID, MesosConfiguration mesosConfiguration) Construct a launchable Mesos worker.
MesosFlinkResourceManager(org.apache.flink.configuration.Configuration flinkConfig, MesosConfiguration mesosConfig, MesosWorkerStore workerStore, org.apache.flink.runtime.leaderretrieval.LeaderRetrievalService leaderRetrievalService, MesosTaskManagerParameters taskManagerParameters, org.apache.flink.runtime.clusterframework.ContainerSpecification taskManagerContainerSpec, MesosArtifactResolver artifactResolver, int maxFailedTasks, int numInitialTaskManagers)
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)

Uses of MesosConfiguration in org.apache.flink.mesos.util

Methods in org.apache.flink.mesos.util that return MesosConfiguration

Modifier and Type	Method and Description
MesosConfiguration	MesosConfiguration.withFrameworkInfo(org.apache.mesos.Protos.FrameworkInfo.Builder frameworkInfo) Revise the configuration with updated framework info.

Methods in org.apache.flink.mesos.util with parameters of type MesosConfiguration

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.