MesosWorkerStore (flink-mesos 1.7.0-mrs-1.8.0 API)

Nested Classes
Modifier and Type	Interface and Description
`static class`	`MesosWorkerStore.Worker` A stored worker.
`static class`	`MesosWorkerStore.WorkerState` The (planned) state of the worker.

Fields
Modifier and Type	Field and Description
`static DecimalFormat`	`TASKID_FORMAT` The template for naming the worker.

All Methods Instance Methods Abstract Methods
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.

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

Get the stored Mesos framework ID.

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

Set the stored Mesos framework ID.

List<MesosWorkerStore.Worker> recoverWorkers()
                                      throws Exception

Recover the stored workers.

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

Generate a new task ID for a worker.

void putWorker(MesosWorkerStore.Worker worker)
        throws Exception

Put a worker into storage.

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

Remove a worker from storage.

Interface MesosWorkerStore