public static class JobManagerMessages.SubmitJob extends Object implements RequiresLeaderSessionID, scala.Product, scala.Serializable
listeningBehaviour
,
the sender registers for different messages. If ListeningBehaviour.DETACHED
, then
it will only be informed whether the submission was successful or not. If
ListeningBehaviour.EXECUTION_RESULT
, then it will additionally receive the execution
result. If ListeningBehaviour.EXECUTION_RESULT_AND_STATE_CHANGES
, then it will additionally
receive the job status change notifications.
The submission result will be sent back to the sender as a success message.
Constructor and Description |
---|
SubmitJob(JobGraph jobGraph,
ListeningBehaviour listeningBehaviour) |
Modifier and Type | Method and Description |
---|---|
JobGraph |
jobGraph() |
ListeningBehaviour |
listeningBehaviour() |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
public SubmitJob(JobGraph jobGraph, ListeningBehaviour listeningBehaviour)
public JobGraph jobGraph()
public ListeningBehaviour listeningBehaviour()
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.