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.
Job Manager, which is responsible for sending the
Task Managerstoring the requested state, and
|Modifier and Type||Method and Description|
Retrieves a future containing the currently leading key-value state location oracle.
Updates the active
void updateKvStateLocationOracle(JobID jobId, @Nullable KvStateLocationOracle kvStateLocationOracle)
Job Managerin 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
jobId- identifying the job for which to update the key-value state location oracle
kvStateLocationOracle- 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
jobId- identifying the job for which to request the key-value state location oracle
JobIDor null if none.
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.