public static class JobManagerMessages.RegisterJobClient extends Object implements RequiresLeaderSessionID, scala.Product, scala.Serializable
JobManagerMessages.RegisterJobClientSuccess
or JobManagerMessages.JobNotFound
if the job was not running.
param: jobID The job id of the job
param: listeningBehaviour The types of updates which will be sent to the sender
after registrationConstructor and Description |
---|
RegisterJobClient(JobID jobID,
ListeningBehaviour listeningBehaviour) |
Modifier and Type | Method and Description |
---|---|
JobID |
jobID() |
ListeningBehaviour |
listeningBehaviour() |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
public RegisterJobClient(JobID jobID, ListeningBehaviour listeningBehaviour)
public JobID jobID()
public ListeningBehaviour listeningBehaviour()
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.