Package | Description |
---|---|
org.apache.flink.client.program | |
org.apache.flink.client.program.rest | |
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.
|
org.apache.flink.runtime.resourcemanager | |
org.apache.flink.yarn |
Class and Description |
---|
GetClusterStatusResponse
The reply to a
GetClusterStatus message sent by the job manager. |
Class and Description |
---|
GetClusterStatusResponse
The reply to a
GetClusterStatus message sent by the job manager. |
Class and Description |
---|
CheckAndAllocateContainers
This message signals the resource master to check how many TaskManagers are
desired, how many are available, and to trigger adjustments if needed.
|
GetClusterStatus
Message sent to the resource manager to request a
GetClusterStatusResponse which contains
the current number of task managers and the total number of task slots. |
RegisterInfoMessageListener
This message signals to the resource master to register the sender as an
info message listener.
|
RegisterInfoMessageListenerSuccessful
This message signals to the application client that the registration was successful.
|
StopClusterSuccessful
Generic message to signal the cluster listener that the cluster has been shut down.
|
UnRegisterInfoMessageListener
This message signals to the resource master to register the sender as an
info message listener.
|
Class and Description |
---|
InfoMessage
A simple informational message sent by the resource master to the client.
|
Class and Description |
---|
GetClusterStatusResponse
The reply to a
GetClusterStatus message sent by the job manager. |
Copyright © 2014–2019 The Apache Software Foundation. All rights reserved.