public interface KvStateLocationLookupService
KvStateLocation
lookup service.Modifier and Type | Method and Description |
---|---|
scala.concurrent.Future<KvStateLocation> |
getKvStateLookupInfo(JobID jobId,
String registrationName)
Returns a future holding the
KvStateLocation for the given job
and KvState registration name. |
void |
shutDown()
Shuts down the lookup service.
|
void |
start()
Starts the lookup service.
|
void start()
void shutDown()
scala.concurrent.Future<KvStateLocation> getKvStateLookupInfo(JobID jobId, String registrationName)
KvStateLocation
for the given job
and KvState registration name.jobId
- JobID the KvState instance belongs toregistrationName
- Name under which the KvState has been registeredKvStateLocation
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.