org.apache.flink.runtime.messages

Class JobClientMessages.SubmitJobAndWait

java.lang.Object

org.apache.flink.runtime.messages.JobClientMessages.SubmitJobAndWait

All Implemented Interfaces:

Serializable, scala.Equals, scala.Product

Enclosing class:

JobClientMessages

public static class JobClientMessages.SubmitJobAndWait
extends Object
implements scala.Product, scala.Serializable

This message is sent to the JobClient (via ask) to submit a job and get a response when the job execution has finished.

The response to this message is a SerializedJobExecutionResult

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
SubmitJobAndWait(JobGraph jobGraph)

Method Summary

Modifier and Type	Method and Description
JobGraph	jobGraph()

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

SubmitJobAndWait

public SubmitJobAndWait(JobGraph jobGraph)

Method Detail

jobGraph

public JobGraph jobGraph()