Uses of Interface
org.apache.flink.runtime.query.KvStateServer

Packages that use KvStateServer

Package	Description
org.apache.flink.queryablestate.client.proxy
org.apache.flink.queryablestate.server
org.apache.flink.runtime.io.network
org.apache.flink.runtime.query

Uses of KvStateServer in org.apache.flink.queryablestate.client.proxy

Classes in org.apache.flink.queryablestate.client.proxy that implement KvStateServer

Modifier and Type	Class and Description
class	KvStateClientProxyImpl The default implementation of the KvStateClientProxy.

Uses of KvStateServer in org.apache.flink.queryablestate.server

Classes in org.apache.flink.queryablestate.server that implement KvStateServer

Modifier and Type	Class and Description
class	KvStateServerImpl The default implementation of the KvStateServer.

Uses of KvStateServer in org.apache.flink.runtime.io.network

Methods in org.apache.flink.runtime.io.network that return KvStateServer

Modifier and Type	Method and Description
KvStateServer	NetworkEnvironment.getKvStateServer()

Constructors in org.apache.flink.runtime.io.network with parameters of type KvStateServer

Constructor and Description

NetworkEnvironment(NetworkBufferPool networkBufferPool, ConnectionManager connectionManager, ResultPartitionManager resultPartitionManager, TaskEventDispatcher taskEventDispatcher, KvStateRegistry kvStateRegistry, KvStateServer kvStateServer, KvStateClientProxy kvStateClientProxy, IOManager.IOMode defaultIOMode, int partitionRequestInitialBackoff, int partitionRequestMaxBackoff, int networkBuffersPerChannel, int extraNetworkBuffersPerGate, boolean enableCreditBased)

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

Subinterfaces of KvStateServer in org.apache.flink.runtime.query

Modifier and Type	Interface and Description
interface	KvStateClientProxy An interface for the Queryable State Client Proxy running on each Task Manager in the cluster.

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

Modifier and Type	Method and Description
static KvStateServer	QueryableStateUtils.createKvStateServer(InetAddress address, Iterator<Integer> ports, int eventLoopThreads, int queryThreads, KvStateRegistry kvStateRegistry, KvStateRequestStats stats) Initializes the server responsible for sending the requested internal state to the client proxy.