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–2019 The Apache Software Foundation. All rights reserved.