Modifier and Type | Class and Description |
---|---|
static class |
JobClientMessages.AttachToJobAndWait
This message is sent to the JobClientActor to ask it to register at the JobManager
and then return once the job execution is complete.
|
static class |
JobClientMessages.AttachToJobAndWait$ |
static class |
JobClientMessages.ConnectionTimeout
Message which is triggered when the connection timeout has been reached.
|
static class |
JobClientMessages.ConnectionTimeout$ |
static class |
JobClientMessages.JobManagerActorRef
Notifies the JobClientActor about the ActorRef of the new leader.
|
static class |
JobClientMessages.JobManagerActorRef$ |
static class |
JobClientMessages.JobManagerLeaderAddress
Notifies the JobClientActor about a new leader address and a leader session ID.
|
static class |
JobClientMessages.JobManagerLeaderAddress$ |
static class |
JobClientMessages.RegistrationTimeout$
Message which is triggered when the JobClient registration at the JobManager times out
|
static class |
JobClientMessages.SubmissionTimeout$
Message which is triggered when the submission timeout has been reached.
|
static class |
JobClientMessages.SubmitJobAndWait
This message is sent to the JobClientActor (via ask) to submit a job and
get a response when the job execution has finished.
|
static class |
JobClientMessages.SubmitJobAndWait$ |
Constructor and Description |
---|
JobClientMessages() |
Modifier and Type | Method and Description |
---|---|
static Object |
getRegistrationTimeout() |
static Object |
getSubmissionTimeout() |
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.