Package | Description |
---|---|
org.apache.flink.queryablestate.client.proxy |
Constructor and Description |
---|
KvStateClientProxyHandler(KvStateClientProxyImpl proxy,
int queryExecutorThreads,
MessageSerializer<KvStateRequest,KvStateResponse> serializer,
KvStateRequestStats stats)
Create the handler used by the
KvStateClientProxyImpl . |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.