org.apache.flink.runtime.client

Class JobAttachmentClientActor

java.lang.Object

akka.actor.UntypedActor

org.apache.flink.runtime.akka.FlinkUntypedActor

org.apache.flink.runtime.client.JobClientActor

org.apache.flink.runtime.client.JobAttachmentClientActor

All Implemented Interfaces:

akka.actor.Actor, LeaderRetrievalListener

public class JobAttachmentClientActor
extends JobClientActor

Actor which handles Job attachment process and provides Job updates until completion.

Nested Class Summary

Nested classes/interfaces inherited from interface akka.actor.Actor

akka.actor.Actor.emptyBehavior$, akka.actor.Actor.ignoringBehavior$

Field Summary

Fields inherited from class org.apache.flink.runtime.client.JobClientActor

client, jobManager, leaderSessionID, timeout

Fields inherited from class org.apache.flink.runtime.akka.FlinkUntypedActor

LOG

Constructor Summary

Constructors

Constructor and Description
JobAttachmentClientActor(LeaderRetrievalService leaderRetrievalService, scala.concurrent.duration.FiniteDuration timeout, boolean sysoutUpdates)

Method Summary

Modifier and Type	Method and Description
void	connectedToJobManager() Hook to be called once a connection has been established with the JobManager.
static akka.actor.Props	createActorProps(LeaderRetrievalService leaderRetrievalService, scala.concurrent.duration.FiniteDuration timeout, boolean sysoutUpdates)
protected Class	getClientMessageClass() Hook to let the client know about messages that should start a timer for a timeout
void	handleCustomMessage(Object message) Hook to handle custom client message which are not handled by the base class.

Methods inherited from class org.apache.flink.runtime.client.JobClientActor

getLeaderSessionID, handleError, handleMessage, isClientConnected, logAndPrintMessage, notifyLeaderAddress, postStop, preStart, terminate

Methods inherited from class org.apache.flink.runtime.akka.FlinkUntypedActor

decorateMessage, onReceive

Methods inherited from class akka.actor.UntypedActor

akka$actor$Actor$_setter_$context_$eq, akka$actor$Actor$_setter_$self_$eq, aroundPostRestart, aroundPostStop, aroundPreRestart, aroundPreStart, aroundReceive, context, getContext, getSelf, getSender, postRestart, preRestart, receive, self, sender, supervisorStrategy, unhandled

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

JobAttachmentClientActor

public JobAttachmentClientActor(LeaderRetrievalService leaderRetrievalService,
                                scala.concurrent.duration.FiniteDuration timeout,
                                boolean sysoutUpdates)

Method Detail

connectedToJobManager

public void connectedToJobManager()

Description copied from class: JobClientActor

Hook to be called once a connection has been established with the JobManager.

Specified by:

connectedToJobManager in class JobClientActor

getClientMessageClass

protected Class getClientMessageClass()

Description copied from class: JobClientActor

Hook to let the client know about messages that should start a timer for a timeout

Specified by:

getClientMessageClass in class JobClientActor

Returns:

The message class after which a timeout should be started

handleCustomMessage

public void handleCustomMessage(Object message)

Description copied from class: JobClientActor

Hook to handle custom client message which are not handled by the base class.

Specified by:

handleCustomMessage in class JobClientActor

Parameters:

message - The message to be handled

createActorProps

public static akka.actor.Props createActorProps(LeaderRetrievalService leaderRetrievalService,
                                                scala.concurrent.duration.FiniteDuration timeout,
                                                boolean sysoutUpdates)