Uses of Class
org.apache.flink.mesos.runtime.clusterframework.MesosTaskManagerParameters

Packages that use MesosTaskManagerParameters

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

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

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

Modifier and Type	Method and Description
static MesosTaskManagerParameters	MesosEntrypointUtils.createTmParameters(org.apache.flink.configuration.Configuration configuration, org.slf4j.Logger log)

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

Methods in org.apache.flink.mesos.runtime.clusterframework that return MesosTaskManagerParameters

Modifier and Type	Method and Description
static MesosTaskManagerParameters	MesosTaskManagerParameters.create(org.apache.flink.configuration.Configuration flinkConfig) Create the Mesos TaskManager parameters.

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

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 MesosTaskManagerParameters

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)