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

Class StandaloneMesosServices

java.lang.Object

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

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

All Implemented Interfaces:

MesosServices

public class StandaloneMesosServices
extends AbstractMesosServices

MesosServices implementation for the standalone mode.

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	StandaloneMesosServices(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.
MesosWorkerStore	createMesosWorkerStore(Configuration configuration, Executor executor) Creates a MesosWorkerStore which is used to persist mesos worker in high availability mode.

Methods inherited from class org.apache.flink.mesos.runtime.clusterframework.services.AbstractMesosServices

getArtifactServer, getLocalActorSystem

Methods inherited from class java.lang.Object

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

Constructor Detail

StandaloneMesosServices

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

Method Detail

createMesosWorkerStore

public MesosWorkerStore createMesosWorkerStore(Configuration configuration,
                                               Executor executor)

Description copied from interface: MesosServices

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

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

Overrides:

close in class AbstractMesosServices

Parameters:

cleanup - is true if a cleanup shall be performed

Throws:

Exception - if the closing operation failed