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.
param: jobGraph The job to be submitted to the JobManager param: listeningBehaviour Specifies to what the sender wants to listen (detached, execution result, execution result and state changes)
|Constructor and Description|
|Modifier and Type||Method and Description|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
productArity, productElement, productIterator, productPrefix
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.