Package org.apache.flink.runtime.query
Interface KvStateServer
-
- All Known Subinterfaces:
KvStateClientProxy
- All Known Implementing Classes:
KvStateClientProxyImpl
,KvStateServerImpl
public interface KvStateServer
An interface for the Queryable State Server running on each Task Manager in the cluster. This server is responsible for serving requests coming from theQueryable State Proxy
and requesting locally stored state.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description InetSocketAddress
getServerAddress()
Returns theaddress
the server is listening to.void
shutdown()
Shuts down the server and all related thread pools.void
start()
Starts the server.
-
-
-
Method Detail
-
getServerAddress
InetSocketAddress getServerAddress()
Returns theaddress
the server is listening to.- Returns:
- Server address.
-
shutdown
void shutdown()
Shuts down the server and all related thread pools.
-
-