public interface KvStateClientProxy extends KvStateServer
This proxy is where the Queryable State Client (potentially running outside your Flink cluster) connects to, and his responsibility is to forward the client's requests to the rest of the entities participating in fetching the requested state, and running within the cluster.
These are:
Job Manager
, which is responsible
for sending the Task Manager
storing the requested state, and
Modifier and Type | Method and Description |
---|---|
KvStateLocationOracle |
getKvStateLocationOracle(JobID jobId)
Retrieves a future containing the currently leading key-value state location oracle.
|
void |
updateKvStateLocationOracle(JobID jobId,
KvStateLocationOracle kvStateLocationOracle)
Updates the active
Job Manager in case
of change. |
getServerAddress, shutdown, start
void updateKvStateLocationOracle(JobID jobId, @Nullable KvStateLocationOracle kvStateLocationOracle)
Job Manager
in case
of change.
This is useful in settings where high-availability is enabled and a failed Job Manager is replaced by a new one.
IMPORTANT: this method may be called by a different thread than the getKvStateLocationOracle(JobID)
.
jobId
- identifying the job for which to update the key-value state location oraclekvStateLocationOracle
- the key-value state location oracle for the given JobID
,
or null if there is no oracle anymore@Nullable KvStateLocationOracle getKvStateLocationOracle(JobID jobId)
IMPORTANT: this method may be called by a different thread than the updateKvStateLocationOracle(JobID, KvStateLocationOracle)
.
jobId
- identifying the job for which to request the key-value state location oracleJobID
or null if none.Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.