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

Class StandaloneMesosWorkerStore

java.lang.Object

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

All Implemented Interfaces:

MesosWorkerStore

public class StandaloneMesosWorkerStore
extends Object
implements MesosWorkerStore

A standalone 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
StandaloneMesosWorkerStore()

Method Summary

Modifier and Type	Method and Description
scala.Option<org.apache.mesos.Protos.FrameworkID>	getFrameworkID() Get the stored Mesos framework ID.
org.apache.mesos.Protos.TaskID	newTaskID() Generate a new task ID for a worker.
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) Set the stored Mesos 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

StandaloneMesosWorkerStore

public StandaloneMesosWorkerStore()

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

Description copied from interface: MesosWorkerStore

Get the stored Mesos framework ID.

Specified by:

getFrameworkID in interface MesosWorkerStore

Throws:

Exception

setFrameworkID

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

Description copied from interface: MesosWorkerStore

Set the stored Mesos framework ID.

Specified by:

setFrameworkID 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

newTaskID

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

Description copied from interface: MesosWorkerStore

Generate a new task ID for a worker.

Specified by:

newTaskID 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