public interface KvStateLocationOracle
KvStateLocationin the cluster. In order to answer
InternalKvStatelocation requests, the
TaskExecutorhave to register and unregister their respective key-value states at the oracle.
|Modifier and Type||Method and Description|
CompletableFuture<KvStateLocation> requestKvStateLocation(JobID jobId, String registrationName)
KvStateLocationfor the specified
jobId- identifying the job for which to request the
registrationName- Name under which the KvState has been registered.
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.