org.apache.flink.mesos.runtime.clusterframework.services

Interface MesosServices

All Known Implementing Classes:

AbstractMesosServices, StandaloneMesosServices, ZooKeeperMesosServices

public interface MesosServices

Service factory interface for Mesos.

Method Summary

Modifier and Type	Method and Description
void	close(boolean cleanup) Closes all state maintained by the mesos services implementation.
MesosWorkerStore	createMesosWorkerStore(org.apache.flink.configuration.Configuration configuration, Executor executor) Creates a MesosWorkerStore which is used to persist mesos worker in high availability mode.
MesosArtifactServer	getArtifactServer() Gets the artifact server with which to serve essential resources to task managers.
akka.actor.ActorSystem	getLocalActorSystem() Gets a local ActorSystem which is used for child actors within MesosResourceManager.

Method Detail

createMesosWorkerStore

MesosWorkerStore createMesosWorkerStore(org.apache.flink.configuration.Configuration configuration,
                                        Executor executor)
                                 throws Exception

Creates a MesosWorkerStore which is used to persist mesos worker in high availability mode.

Parameters:

configuration - to be used

executor - to run asynchronous tasks

Returns:

a mesos worker store

Throws:

Exception - if the mesos worker store could not be created

getLocalActorSystem

akka.actor.ActorSystem getLocalActorSystem()

Gets a local ActorSystem which is used for child actors within MesosResourceManager.

Returns:

a reference to an actor system.

getArtifactServer

MesosArtifactServer getArtifactServer()

Gets the artifact server with which to serve essential resources to task managers.

Returns:

a reference to an artifact server.

close

void close(boolean cleanup)
    throws Exception

Closes all state maintained by the mesos services implementation.

Parameters:

cleanup - is true if a cleanup shall be performed

Throws:

Exception - if the closing operation failed