Package | Description |
---|---|
org.apache.flink.queryablestate.client.proxy | |
org.apache.flink.queryablestate.network | |
org.apache.flink.queryablestate.server |
Modifier and Type | Class and Description |
---|---|
class |
KvStateClientProxyHandler
This handler acts as an internal (to the Flink cluster) client that receives the requests from
external clients, executes them by contacting the Job Manager (if necessary) and the Task Manager
holding the requested state, and forwards the answer back to the client.
|
Modifier and Type | Method and Description |
---|---|
AbstractServerHandler<KvStateRequest,KvStateResponse> |
KvStateClientProxyImpl.initializeHandler() |
Modifier and Type | Method and Description |
---|---|
abstract AbstractServerHandler<REQ,RESP> |
AbstractServerBase.initializeHandler()
Returns the
handler to be used for serving the incoming
requests. |
Modifier and Type | Class and Description |
---|---|
class |
KvStateServerHandler
This handler dispatches asynchronous tasks, which query
InternalKvState instances and
write the result to the channel. |
Modifier and Type | Method and Description |
---|---|
AbstractServerHandler<KvStateInternalRequest,KvStateResponse> |
KvStateServerImpl.initializeHandler() |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.