Uses of Class
org.apache.flink.queryablestate.KvStateID

Packages that use KvStateID

Package	Description
org.apache.flink.queryablestate.exceptions
org.apache.flink.queryablestate.messages
org.apache.flink.runtime.jobmaster
org.apache.flink.runtime.query
org.apache.flink.runtime.scheduler
org.apache.flink.runtime.scheduler.adaptive
org.apache.flink.runtime.taskexecutor.rpc

Uses of KvStateID in org.apache.flink.queryablestate.exceptions

Constructors in org.apache.flink.queryablestate.exceptions with parameters of type KvStateID

Constructor and Description
UnknownKvStateIdException(String serverName, KvStateID kvStateId) Creates the exception.

Uses of KvStateID in org.apache.flink.queryablestate.messages

Methods in org.apache.flink.queryablestate.messages that return KvStateID

Modifier and Type	Method and Description
KvStateID	KvStateInternalRequest.getKvStateId()

Constructors in org.apache.flink.queryablestate.messages with parameters of type KvStateID

Constructor and Description
KvStateInternalRequest(KvStateID stateId, byte[] serializedKeyAndNamespace)

Uses of KvStateID in org.apache.flink.runtime.jobmaster

Methods in org.apache.flink.runtime.jobmaster with parameters of type KvStateID

Modifier and Type	Method and Description
CompletableFuture<Acknowledge>	JobMaster.notifyKvStateRegistered(JobID jobId, JobVertexID jobVertexId, KeyGroupRange keyGroupRange, String registrationName, KvStateID kvStateId, InetSocketAddress kvStateServerAddress)
CompletableFuture<Acknowledge>	KvStateRegistryGateway.notifyKvStateRegistered(JobID jobId, JobVertexID jobVertexId, KeyGroupRange keyGroupRange, String registrationName, KvStateID kvStateId, InetSocketAddress kvStateServerAddress) Notifies that queryable state has been registered.

Uses of KvStateID in org.apache.flink.runtime.query

Methods in org.apache.flink.runtime.query that return KvStateID

Modifier and Type	Method and Description
KvStateID	KvStateLocation.getKvStateID(int keyGroupIndex) Returns the registered KvStateID for the key group index or null if none is registered yet.
KvStateID	KvStateRegistry.registerKvState(JobID jobId, JobVertexID jobVertexId, KeyGroupRange keyGroupRange, String registrationName, InternalKvState<?,?,?> kvState, ClassLoader userClassLoader) Registers the KvState instance and returns the assigned ID.

Methods in org.apache.flink.runtime.query with parameters of type KvStateID

Modifier and Type	Method and Description
KvStateEntry<?,?,?>	KvStateRegistry.getKvState(KvStateID kvStateId) Returns the KvStateEntry containing the requested instance as identified by the given KvStateID, along with its KvStateInfo or null if none is registered.
void	KvStateRegistryListener.notifyKvStateRegistered(JobID jobId, JobVertexID jobVertexId, KeyGroupRange keyGroupRange, String registrationName, KvStateID kvStateId) Notifies the listener about a registered KvState instance.
void	KvStateLocationRegistry.notifyKvStateRegistered(JobVertexID jobVertexId, KeyGroupRange keyGroupRange, String registrationName, KvStateID kvStateId, InetSocketAddress kvStateServerAddress) Notifies the registry about a registered KvState instance.
void	KvStateLocation.registerKvState(KeyGroupRange keyGroupRange, KvStateID kvStateId, InetSocketAddress kvStateAddress) Registers a KvState instance for the given key group index.
void	KvStateRegistry.unregisterKvState(JobID jobId, JobVertexID jobVertexId, KeyGroupRange keyGroupRange, String registrationName, KvStateID kvStateId) Unregisters the KvState instance identified by the given KvStateID.

Uses of KvStateID in org.apache.flink.runtime.scheduler

Methods in org.apache.flink.runtime.scheduler with parameters of type KvStateID

Modifier and Type	Method and Description
void	SchedulerBase.notifyKvStateRegistered(JobID jobId, JobVertexID jobVertexId, KeyGroupRange keyGroupRange, String registrationName, KvStateID kvStateId, InetSocketAddress kvStateServerAddress)
void	SchedulerNG.notifyKvStateRegistered(JobID jobId, JobVertexID jobVertexId, KeyGroupRange keyGroupRange, String registrationName, KvStateID kvStateId, InetSocketAddress kvStateServerAddress)
void	KvStateHandler.notifyKvStateRegistered(JobID jobId, JobVertexID jobVertexId, KeyGroupRange keyGroupRange, String registrationName, KvStateID kvStateId, InetSocketAddress kvStateServerAddress)

Uses of KvStateID in org.apache.flink.runtime.scheduler.adaptive

Methods in org.apache.flink.runtime.scheduler.adaptive with parameters of type KvStateID

Modifier and Type	Method and Description
void	AdaptiveScheduler.notifyKvStateRegistered(JobID jobId, JobVertexID jobVertexId, KeyGroupRange keyGroupRange, String registrationName, KvStateID kvStateId, InetSocketAddress kvStateServerAddress)

Uses of KvStateID in org.apache.flink.runtime.taskexecutor.rpc

Methods in org.apache.flink.runtime.taskexecutor.rpc with parameters of type KvStateID

Modifier and Type	Method and Description
void	RpcKvStateRegistryListener.notifyKvStateRegistered(JobID jobId, JobVertexID jobVertexId, KeyGroupRange keyGroupRange, String registrationName, KvStateID kvStateId)