Class TaskExecutorRegistrationSuccess

    • Constructor Detail

      • TaskExecutorRegistrationSuccess

        public TaskExecutorRegistrationSuccess​(InstanceID registrationId,
                                               ResourceID resourceManagerResourceId,
                                               ClusterInformation clusterInformation,
                                               @Nullable
                                               byte[] initialTokens)
        Create a new TaskExecutorRegistrationSuccess message.
        Parameters:
        registrationId - The ID that the ResourceManager assigned the registration.
        resourceManagerResourceId - The unique ID that identifies the ResourceManager.
        clusterInformation - information about the cluster
        initialTokens - 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.