Class | Description |
---|---|
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.
|
KvStateClientProxyImpl |
The default implementation of the
KvStateClientProxy . |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.