Uses of Interface
org.apache.flink.mesos.runtime.clusterframework.store.MesosWorkerStore

Packages that use MesosWorkerStore

Package	Description
org.apache.flink.mesos.runtime.clusterframework
org.apache.flink.mesos.runtime.clusterframework.services
org.apache.flink.mesos.runtime.clusterframework.store

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

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

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 MesosWorkerStore

Constructor and Description

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)

Uses of MesosWorkerStore in org.apache.flink.mesos.runtime.clusterframework.services

Methods in org.apache.flink.mesos.runtime.clusterframework.services that return MesosWorkerStore

Modifier and Type	Method and Description
MesosWorkerStore	StandaloneMesosServices.createMesosWorkerStore(org.apache.flink.configuration.Configuration configuration, Executor executor)
MesosWorkerStore	MesosServices.createMesosWorkerStore(org.apache.flink.configuration.Configuration configuration, Executor executor) Creates a MesosWorkerStore which is used to persist mesos worker in high availability mode.
MesosWorkerStore	ZooKeeperMesosServices.createMesosWorkerStore(org.apache.flink.configuration.Configuration configuration, Executor executor)

Uses of MesosWorkerStore in org.apache.flink.mesos.runtime.clusterframework.store

Classes in org.apache.flink.mesos.runtime.clusterframework.store that implement MesosWorkerStore

Modifier and Type	Class and Description
class	StandaloneMesosWorkerStore A standalone Mesos worker store.
class	ZooKeeperMesosWorkerStore A ZooKeeper-backed Mesos worker store.