Class TaskExecutorRegistrationSuccess
- java.lang.Object
-
- org.apache.flink.runtime.registration.RegistrationResponse
-
- org.apache.flink.runtime.registration.RegistrationResponse.Success
-
- org.apache.flink.runtime.taskexecutor.TaskExecutorRegistrationSuccess
-
- All Implemented Interfaces:
Serializable
public final class TaskExecutorRegistrationSuccess extends RegistrationResponse.Success implements Serializable
Base class for responses from the ResourceManager to a registration attempt by a TaskExecutor.- See Also:
- Serialized Form
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from class org.apache.flink.runtime.registration.RegistrationResponse
RegistrationResponse.Failure, RegistrationResponse.Rejection, RegistrationResponse.Success
-
-
Constructor Summary
Constructors Constructor Description TaskExecutorRegistrationSuccess(InstanceID registrationId, ResourceID resourceManagerResourceId, ClusterInformation clusterInformation, byte[] initialTokens)
Create a newTaskExecutorRegistrationSuccess
message.
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description ClusterInformation
getClusterInformation()
Gets the cluster information.byte[]
getInitialTokens()
Gets the initial tokens.InstanceID
getRegistrationId()
Gets the ID that the ResourceManager assigned the registration.ResourceID
getResourceManagerId()
Gets the unique ID that identifies the ResourceManager.String
toString()
-
-
-
Constructor Detail
-
TaskExecutorRegistrationSuccess
public TaskExecutorRegistrationSuccess(InstanceID registrationId, ResourceID resourceManagerResourceId, ClusterInformation clusterInformation, @Nullable byte[] initialTokens)
Create a newTaskExecutorRegistrationSuccess
message.- Parameters:
registrationId
- The ID that the ResourceManager assigned the registration.resourceManagerResourceId
- The unique ID that identifies the ResourceManager.clusterInformation
- information about the clusterinitialTokens
- initial tokens for the TaskExecutor
-
-
Method Detail
-
getRegistrationId
public InstanceID getRegistrationId()
Gets the ID that the ResourceManager assigned the registration.
-
getResourceManagerId
public ResourceID getResourceManagerId()
Gets the unique ID that identifies the ResourceManager.
-
getClusterInformation
public ClusterInformation getClusterInformation()
Gets the cluster information.
-
getInitialTokens
public byte[] getInitialTokens()
Gets the initial tokens.
-
toString
public String toString()
- Overrides:
toString
in classRegistrationResponse.Success
-
-