Package | Description |
---|---|
org.apache.flink.mesos.runtime.clusterframework |
Modifier and Type | Method and Description |
---|---|
protected RegisteredMesosWorkerNode |
MesosFlinkResourceManager.workerStarted(ResourceID resourceID)
Accept the given started worker into the internal state.
|
protected RegisteredMesosWorkerNode |
MesosResourceManager.workerStarted(ResourceID resourceID)
Callback when a worker was started.
|
Modifier and Type | Method and Description |
---|---|
protected Collection<RegisteredMesosWorkerNode> |
MesosFlinkResourceManager.reacceptRegisteredWorkers(Collection<ResourceID> toConsolidate)
Accept the given registered workers into the internal state.
|
Modifier and Type | Method and Description |
---|---|
protected void |
MesosFlinkResourceManager.releaseStartedWorker(RegisteredMesosWorkerNode worker)
Release the given started worker.
|
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.