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

Class AbstractMesosServices

java.lang.Object

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

All Implemented Interfaces:

MesosServices

Direct Known Subclasses:

StandaloneMesosServices, ZooKeeperMesosServices

public abstract class AbstractMesosServices
extends Object
implements MesosServices

An abstract implementation of MesosServices.

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	AbstractMesosServices(akka.actor.ActorSystem actorSystem, MesosArtifactServer artifactServer)

Method Summary

Modifier and Type	Method and Description
void	close(boolean cleanup) Closes all state maintained by the mesos services implementation.
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.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.flink.mesos.runtime.clusterframework.services.MesosServices

createMesosWorkerStore

Constructor Detail

AbstractMesosServices

protected AbstractMesosServices(akka.actor.ActorSystem actorSystem,
                                MesosArtifactServer artifactServer)

Method Detail

getLocalActorSystem

public akka.actor.ActorSystem getLocalActorSystem()

Description copied from interface: MesosServices

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

Specified by:

getLocalActorSystem in interface MesosServices

Returns:

a reference to an actor system.

getArtifactServer

public MesosArtifactServer getArtifactServer()

Description copied from interface: MesosServices

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

Specified by:

getArtifactServer in interface MesosServices

Returns:

a reference to an artifact server.

close

public void close(boolean cleanup)
           throws Exception

Description copied from interface: MesosServices

Closes all state maintained by the mesos services implementation.

Specified by:

close in interface MesosServices

Parameters:

cleanup - is true if a cleanup shall be performed

Throws:

Exception - if the closing operation failed