Package org.apache.flink.runtime.client

Class Summary

Class	Description
JobAttachmentClientActor	Actor which handles Job attachment process and provides Job updates until completion.
JobClient	The JobClient bridges between the JobManager's asynchronous actor messages and the synchronous method calls to trigger.
JobClientActor	Actor which constitutes the bridge between the non-actor code and the JobManager.
JobListeningContext	The JobListeningContext holds the state necessary to monitor a running job and receive its results.
JobStatusMessage	A simple message that holds the state of a job execution.
JobSubmissionClientActor	Actor which handles Job submission process and provides Job updates until completion.
SerializedJobExecutionResult	A variant of the JobExecutionResult that holds its accumulator data in serialized form.

Enum Summary

Enum	Description
ClientUtils	Contains utility methods for clients.

Exception Summary

Exception	Description
JobCancellationException	An exception which is thrown by the JobClient if a job is aborted as a result of a user cancellation.
JobClientActorConnectionTimeoutException	Exception which is thrown when the JobClientActor wants to submit a job to the job manager but has not found one after a given timeout interval.
JobClientActorRegistrationTimeoutException	Exception which is thrown by the JobClientActor if it has not heard back from the job manager after it has attempted to register for a job within a given timeout interval.
JobClientActorSubmissionTimeoutException	Exception which is thrown by the JobClientActor if it has not heard back from the job manager after it has submitted a job to it within a given timeout interval.
JobExecutionException	This exception is the base exception for all exceptions that denote any failure during the execution of a job.
JobRetrievalException	Exception used to indicate that a job couldn't be retrieved from the JobManager
JobSubmissionException	This exception denotes an error while submitting a job to the JobManager.
JobTimeoutException	An exception which is thrown by the JobClient if the job manager is no longer reachable.