Interface KvStateLocationOracle
-
- All Known Subinterfaces:
JobMasterGateway
- All Known Implementing Classes:
JobMaster
public interface KvStateLocationOracle
Oracle forKvStateLocation
in the cluster. In order to answerInternalKvState
location requests, theTaskExecutor
have to register and unregister their respective key-value states at the oracle.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description CompletableFuture<KvStateLocation>
requestKvStateLocation(JobID jobId, String registrationName)
Requests aKvStateLocation
for the specifiedInternalKvState
registration name.
-
-
-
Method Detail
-
requestKvStateLocation
CompletableFuture<KvStateLocation> requestKvStateLocation(JobID jobId, String registrationName)
Requests aKvStateLocation
for the specifiedInternalKvState
registration name.- Parameters:
jobId
- identifying the job for which to request theKvStateLocation
registrationName
- Name under which the KvState has been registered.- Returns:
- Future of the requested
InternalKvState
location
-
-