Uses of Class
org.apache.flink.mesos.runtime.clusterframework.RegisteredMesosWorkerNode

Packages that use RegisteredMesosWorkerNode

Package	Description
org.apache.flink.mesos.runtime.clusterframework

Uses of RegisteredMesosWorkerNode in org.apache.flink.mesos.runtime.clusterframework

Methods in org.apache.flink.mesos.runtime.clusterframework that return RegisteredMesosWorkerNode

Modifier and Type	Method and Description
protected RegisteredMesosWorkerNode	MesosResourceManager.workerStarted(org.apache.flink.runtime.clusterframework.types.ResourceID resourceID) Callback when a worker was started.
protected RegisteredMesosWorkerNode	MesosFlinkResourceManager.workerStarted(org.apache.flink.runtime.clusterframework.types.ResourceID resourceID) Accept the given started worker into the internal state.

Methods in org.apache.flink.mesos.runtime.clusterframework that return types with arguments of type RegisteredMesosWorkerNode

Modifier and Type	Method and Description
org.apache.flink.runtime.resourcemanager.ResourceManager<RegisteredMesosWorkerNode>	MesosResourceManagerFactory.createResourceManager(org.apache.flink.configuration.Configuration configuration, org.apache.flink.runtime.clusterframework.types.ResourceID resourceId, org.apache.flink.runtime.rpc.RpcService rpcService, org.apache.flink.runtime.highavailability.HighAvailabilityServices highAvailabilityServices, org.apache.flink.runtime.heartbeat.HeartbeatServices heartbeatServices, org.apache.flink.runtime.metrics.MetricRegistry metricRegistry, org.apache.flink.runtime.rpc.FatalErrorHandler fatalErrorHandler, org.apache.flink.runtime.entrypoint.ClusterInformation clusterInformation, String webInterfaceUrl, org.apache.flink.runtime.metrics.groups.JobManagerMetricGroup jobManagerMetricGroup)
protected Collection<RegisteredMesosWorkerNode>	MesosFlinkResourceManager.reacceptRegisteredWorkers(Collection<org.apache.flink.runtime.clusterframework.types.ResourceID> toConsolidate) Accept the given registered workers into the internal state.

Methods in org.apache.flink.mesos.runtime.clusterframework with parameters of type RegisteredMesosWorkerNode

Modifier and Type	Method and Description
protected void	MesosFlinkResourceManager.releaseStartedWorker(RegisteredMesosWorkerNode worker) Release the given started worker.
boolean	MesosResourceManager.stopWorker(RegisteredMesosWorkerNode workerNode)