public static class KvStateMessage.NotifyKvStateRegistered extends Object implements KvStateMessage
KvState
registration.KvStateMessage.LookupKvStateLocation, KvStateMessage.NotifyKvStateRegistered, KvStateMessage.NotifyKvStateUnregistered
Constructor and Description |
---|
NotifyKvStateRegistered(JobID jobId,
JobVertexID jobVertexId,
KeyGroupRange keyGroupRange,
String registrationName,
KvStateID kvStateId,
InetSocketAddress kvStateServerAddress)
Notifies the JobManager about a registered
InternalKvState instance. |
Modifier and Type | Method and Description |
---|---|
JobID |
getJobId()
Returns the JobID the KvState instance belongs to.
|
JobVertexID |
getJobVertexId()
Returns the JobVertexID the KvState instance belongs to.
|
KeyGroupRange |
getKeyGroupRange()
Returns the key group index the KvState instance belongs to.
|
KvStateID |
getKvStateId()
Returns the ID of the registered KvState instance.
|
InetSocketAddress |
getKvStateServerAddress()
Returns the server address where to find the KvState instance.
|
String |
getRegistrationName()
Returns the name under which the KvState has been registered.
|
String |
toString() |
public NotifyKvStateRegistered(JobID jobId, JobVertexID jobVertexId, KeyGroupRange keyGroupRange, String registrationName, KvStateID kvStateId, InetSocketAddress kvStateServerAddress)
InternalKvState
instance.jobId
- JobID the KvState instance belongs tojobVertexId
- JobVertexID the KvState instance belongs tokeyGroupRange
- Key group range the KvState instance belongs toregistrationName
- Name under which the KvState has been registeredkvStateId
- ID of the registered KvState instancekvStateServerAddress
- Server address where to find the KvState instancepublic JobID getJobId()
public JobVertexID getJobVertexId()
public KeyGroupRange getKeyGroupRange()
public String getRegistrationName()
public KvStateID getKvStateId()
public InetSocketAddress getKvStateServerAddress()
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.