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