org.apache.flink.runtime.messages

Class RegistrationMessages.AcknowledgeRegistration

java.lang.Object

org.apache.flink.runtime.messages.RegistrationMessages.AcknowledgeRegistration

All Implemented Interfaces:

Serializable, RegistrationMessages.RegistrationMessage, RequiresLeaderSessionID, scala.Equals, scala.Product

Enclosing class:

RegistrationMessages

public static class RegistrationMessages.AcknowledgeRegistration
extends Object
implements RegistrationMessages.RegistrationMessage, scala.Product, scala.Serializable

Denotes the successful registration of a task manager at the job manager. This is the response triggered by the RegistrationMessages.RegisterTaskManager message.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
AcknowledgeRegistration(InstanceID instanceID, int blobPort)

Method Summary

Modifier and Type	Method and Description
int	blobPort()
InstanceID	instanceID()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface scala.Product

productArity, productElement, productIterator, productPrefix

Methods inherited from interface scala.Equals

canEqual, equals

Constructor Detail

AcknowledgeRegistration

public AcknowledgeRegistration(InstanceID instanceID,
                               int blobPort)

Method Detail

instanceID

public InstanceID instanceID()

blobPort

public int blobPort()