public class JobSubmissionClientActor extends JobClientActor
client, jobManager, leaderSessionID, timeout
LOG
Constructor and Description |
---|
JobSubmissionClientActor(LeaderRetrievalService leaderRetrievalService,
scala.concurrent.duration.FiniteDuration timeout,
boolean sysoutUpdates,
Configuration clientConfig) |
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,
Configuration clientConfig) |
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.
|
getLeaderSessionID, handleError, handleMessage, isClientConnected, logAndPrintMessage, notifyLeaderAddress, postStop, preStart, terminate
decorateMessage, onReceive
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
public JobSubmissionClientActor(LeaderRetrievalService leaderRetrievalService, scala.concurrent.duration.FiniteDuration timeout, boolean sysoutUpdates, Configuration clientConfig)
public void connectedToJobManager()
JobClientActor
connectedToJobManager
in class JobClientActor
protected Class getClientMessageClass()
JobClientActor
getClientMessageClass
in class JobClientActor
public void handleCustomMessage(Object message)
JobClientActor
handleCustomMessage
in class JobClientActor
message
- The message to be handledpublic static akka.actor.Props createActorProps(LeaderRetrievalService leaderRetrievalService, scala.concurrent.duration.FiniteDuration timeout, boolean sysoutUpdates, Configuration clientConfig)
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.