org.apache.flink.mesos.runtime.clusterframework.store

Class ZooKeeperMesosWorkerStore

java.lang.Object

org.apache.flink.mesos.runtime.clusterframework.store.ZooKeeperMesosWorkerStore

All Implemented Interfaces:

MesosWorkerStore

public class ZooKeeperMesosWorkerStore
extends Object
implements MesosWorkerStore

A ZooKeeper-backed Mesos worker store.

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.flink.mesos.runtime.clusterframework.store.MesosWorkerStore

MesosWorkerStore.Worker, MesosWorkerStore.WorkerState

Field Summary

Fields inherited from interface org.apache.flink.mesos.runtime.clusterframework.store.MesosWorkerStore

TASKID_FORMAT

Constructor Summary

Constructors

Constructor and Description
ZooKeeperMesosWorkerStore(org.apache.flink.runtime.zookeeper.ZooKeeperStateHandleStore<MesosWorkerStore.Worker> workersInZooKeeper, org.apache.flink.runtime.zookeeper.ZooKeeperSharedValue frameworkIdInZooKeeper, org.apache.flink.runtime.zookeeper.ZooKeeperSharedCount totalTaskCountInZooKeeper)

Method Summary

Modifier and Type	Method and Description
scala.Option<org.apache.mesos.Protos.FrameworkID>	getFrameworkID() Get the persisted framework ID.
org.apache.mesos.Protos.TaskID	newTaskID() Generates a new task ID.
void	putWorker(MesosWorkerStore.Worker worker) Put a worker into storage.
List<MesosWorkerStore.Worker>	recoverWorkers() Recover the stored workers.
boolean	removeWorker(org.apache.mesos.Protos.TaskID taskID) Remove a worker from storage.
void	setFrameworkID(scala.Option<org.apache.mesos.Protos.FrameworkID> frameworkID) Update the persisted framework ID.
void	start() Start the worker store.
void	stop(boolean cleanup) Stop the worker store.

Methods inherited from class java.lang.Object

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

Constructor Detail

ZooKeeperMesosWorkerStore

public ZooKeeperMesosWorkerStore(org.apache.flink.runtime.zookeeper.ZooKeeperStateHandleStore<MesosWorkerStore.Worker> workersInZooKeeper,
                                 org.apache.flink.runtime.zookeeper.ZooKeeperSharedValue frameworkIdInZooKeeper,
                                 org.apache.flink.runtime.zookeeper.ZooKeeperSharedCount totalTaskCountInZooKeeper)
                          throws Exception

Throws:

Exception

Method Detail

start

public void start()
           throws Exception

Description copied from interface: MesosWorkerStore

Start the worker store.

Specified by:

start in interface MesosWorkerStore

Throws:

Exception

stop

public void stop(boolean cleanup)
          throws Exception

Description copied from interface: MesosWorkerStore

Stop the worker store.

Specified by:

stop in interface MesosWorkerStore

Parameters:

cleanup - if true, cleanup any stored information.

Throws:

Exception

getFrameworkID

public scala.Option<org.apache.mesos.Protos.FrameworkID> getFrameworkID()
                                                                 throws Exception

Get the persisted framework ID.

Specified by:

getFrameworkID in interface MesosWorkerStore

Returns:

the current ID or empty if none is yet persisted.

Throws:

Exception - on ZK failures, interruptions.

setFrameworkID

public void setFrameworkID(scala.Option<org.apache.mesos.Protos.FrameworkID> frameworkID)
                    throws Exception

Update the persisted framework ID.

Specified by:

setFrameworkID in interface MesosWorkerStore

Parameters:

frameworkID - the new ID or empty to remove the persisted ID.

Throws:

Exception - on ZK failures, interruptions.

newTaskID

public org.apache.mesos.Protos.TaskID newTaskID()
                                         throws Exception

Generates a new task ID.

Specified by:

newTaskID in interface MesosWorkerStore

Throws:

Exception

recoverWorkers

public List<MesosWorkerStore.Worker> recoverWorkers()
                                             throws Exception

Description copied from interface: MesosWorkerStore

Recover the stored workers.

Specified by:

recoverWorkers in interface MesosWorkerStore

Throws:

Exception

putWorker

public void putWorker(MesosWorkerStore.Worker worker)
               throws Exception

Description copied from interface: MesosWorkerStore

Put a worker into storage.

Specified by:

putWorker in interface MesosWorkerStore

Throws:

Exception

removeWorker

public boolean removeWorker(org.apache.mesos.Protos.TaskID taskID)
                     throws Exception

Description copied from interface: MesosWorkerStore

Remove a worker from storage.

Specified by:

removeWorker in interface MesosWorkerStore

Returns:

true if the worker existed.

Throws:

Exception