org.apache.flink.runtime.messages

Class RegistrationMessages.TriggerTaskManagerRegistration

java.lang.Object

org.apache.flink.runtime.messages.RegistrationMessages.TriggerTaskManagerRegistration

All Implemented Interfaces:

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

Enclosing class:

RegistrationMessages

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

Triggers the TaskManager to attempt a registration at the JobManager.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
TriggerTaskManagerRegistration(String jobManagerURL, scala.concurrent.duration.FiniteDuration timeout, scala.Option<scala.concurrent.duration.Deadline> deadline, int attempt)

Method Summary

Modifier and Type	Method and Description
int	attempt()
scala.Option<scala.concurrent.duration.Deadline>	deadline()
String	jobManagerURL()
scala.concurrent.duration.FiniteDuration	timeout()

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

TriggerTaskManagerRegistration

public TriggerTaskManagerRegistration(String jobManagerURL,
                                      scala.concurrent.duration.FiniteDuration timeout,
                                      scala.Option<scala.concurrent.duration.Deadline> deadline,
                                      int attempt)

Method Detail

jobManagerURL

public String jobManagerURL()

timeout

public scala.concurrent.duration.FiniteDuration timeout()

deadline

public scala.Option<scala.concurrent.duration.Deadline> deadline()

attempt

public int attempt()