Package | Description |
---|---|
org.apache.flink.runtime.clusterframework.messages |
This package contains the actor messages that are sent between the
cluster resource framework and the JobManager, as well as the generic
messages sent between the cluster resource framework and the client.
|
Modifier and Type | Class and Description |
---|---|
class |
NotifyResourceStarted
Notifies the ResourceManager that a TaskManager has been started in a container with the given
resource id.
|
class |
ReconnectResourceManager
This message signals that the ResourceManager should reconnect to the JobManager.
|
class |
RegisterInfoMessageListener
This message signals to the resource master to register the sender as an
info message listener.
|
class |
RegisterInfoMessageListenerSuccessful
This message signals to the application client that the registration was successful.
|
class |
RegisterResourceManager
This message signals that the resource manager wants to register at the JobManager leader.
|
class |
RegisterResourceManagerSuccessful
Message that informs the resource manager that the JobManager accepted its registration.
|
class |
RemoveResource
Message sent to the ResourceManager by the JobManager to instruct to remove a resource.
|
class |
ResourceRemoved
Message sent to the JobManager by the Resource Manager to inform
about the removal of a resource.
|
class |
SetWorkerPoolSize
Message sent to the resource master actor to adjust the designated number of
workers it maintains.
|
class |
StopCluster
Generic message to signal the cluster framework to shut the cluster down.
|
class |
StopClusterSuccessful
Generic message to signal the cluster listener that the cluster has been shut down.
|
class |
TriggerRegistrationAtJobManager
Causes the resource manager to try and apply at the leader JobManager.
|
class |
UnRegisterInfoMessageListener
This message signals to the resource master to register the sender as an
info message listener.
|
Copyright © 2014–2019 The Apache Software Foundation. All rights reserved.