public static class KvStateMessage.NotifyKvStateUnregistered extends Object implements KvStateMessage
KvState
unregistration.KvStateMessage.LookupKvStateLocation, KvStateMessage.NotifyKvStateRegistered, KvStateMessage.NotifyKvStateUnregistered
Constructor and Description |
---|
NotifyKvStateUnregistered(JobID jobId,
JobVertexID jobVertexId,
KeyGroupRange keyGroupRange,
String registrationName)
Notifies the JobManager about an unregistered
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.
|
String |
getRegistrationName()
Returns the name under which the KvState has been registered.
|
String |
toString() |
public NotifyKvStateUnregistered(JobID jobId, JobVertexID jobVertexId, KeyGroupRange keyGroupRange, String registrationName)
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 registeredpublic JobID getJobId()
public JobVertexID getJobVertexId()
public KeyGroupRange getKeyGroupRange()
public String getRegistrationName()
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.