public static class RegistrationMessages.TriggerTaskManagerRegistration extends Object implements RegistrationMessages.RegistrationMessage, scala.Product, scala.Serializable
param: jobManagerURL Akka URL to the JobManager param: timeout The timeout for the message. The next retry will double this timeout. param: deadline Optional deadline until when the registration must be completed. param: attempt The attempt number, for logging. param: registrationRun UUID of the current registration run to filter out outdated runs
Constructor and Description |
---|
TriggerTaskManagerRegistration(String jobManagerURL,
scala.concurrent.duration.FiniteDuration timeout,
scala.Option<scala.concurrent.duration.Deadline> deadline,
int attempt,
UUID registrationRun) |
Modifier and Type | Method and Description |
---|---|
int |
attempt() |
scala.Option<scala.concurrent.duration.Deadline> |
deadline() |
String |
jobManagerURL() |
UUID |
registrationRun() |
scala.concurrent.duration.FiniteDuration |
timeout() |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.