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

Class ZooKeeperMesosServices

java.lang.Object

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

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

All Implemented Interfaces:

MesosServices

public class ZooKeeperMesosServices
extends AbstractMesosServices

MesosServices implementation for the ZooKeeper high availability based mode.

Constructor Summary

Constructors

Constructor and Description
ZooKeeperMesosServices(akka.actor.ActorSystem actorSystem, MesosArtifactServer artifactServer, org.apache.flink.runtime.zookeeper.ZooKeeperUtilityFactory zooKeeperUtilityFactory)

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.

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

ZooKeeperMesosServices

public ZooKeeperMesosServices(akka.actor.ActorSystem actorSystem,
                              MesosArtifactServer artifactServer,
                              org.apache.flink.runtime.zookeeper.ZooKeeperUtilityFactory zooKeeperUtilityFactory)

Method Detail

createMesosWorkerStore

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

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

Throws:

Exception - if the mesos worker store could not be created

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