Package | Description |
---|---|
org.apache.flink.mesos.runtime.clusterframework | |
org.apache.flink.mesos.runtime.clusterframework.store |
Modifier and Type | Method and Description |
---|---|
MesosWorkerStore.Worker |
RegisteredMesosWorkerNode.getWorker() |
Constructor and Description |
---|
RegisteredMesosWorkerNode(MesosWorkerStore.Worker worker) |
Modifier and Type | Method and Description |
---|---|
MesosWorkerStore.Worker |
MesosWorkerStore.Worker.launchWorker(org.apache.mesos.Protos.SlaveID slaveID,
String hostname)
Transition the worker to a launched state.
|
static MesosWorkerStore.Worker |
MesosWorkerStore.Worker.newWorker(org.apache.mesos.Protos.TaskID taskID,
WorkerResourceSpec workerResourceSpec)
Create a new worker with the given taskID.
|
MesosWorkerStore.Worker |
MesosWorkerStore.Worker.releaseWorker()
Transition the worker to a released state.
|
Modifier and Type | Method and Description |
---|---|
List<MesosWorkerStore.Worker> |
MesosWorkerStore.recoverWorkers()
Recover the stored workers.
|
List<MesosWorkerStore.Worker> |
StandaloneMesosWorkerStore.recoverWorkers() |
List<MesosWorkerStore.Worker> |
ZooKeeperMesosWorkerStore.recoverWorkers() |
Modifier and Type | Method and Description |
---|---|
void |
MesosWorkerStore.putWorker(MesosWorkerStore.Worker worker)
Put a worker into storage.
|
void |
StandaloneMesosWorkerStore.putWorker(MesosWorkerStore.Worker worker) |
void |
ZooKeeperMesosWorkerStore.putWorker(MesosWorkerStore.Worker worker) |
Constructor and Description |
---|
ZooKeeperMesosWorkerStore(ZooKeeperStateHandleStore<MesosWorkerStore.Worker> workersInZooKeeper,
ZooKeeperSharedValue frameworkIdInZooKeeper,
ZooKeeperSharedCount totalTaskCountInZooKeeper) |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.