Package | Description |
---|---|
org.apache.flink.queryablestate.client.proxy | |
org.apache.flink.runtime.query | |
org.apache.flink.runtime.taskexecutor |
Modifier and Type | Class and Description |
---|---|
class |
KvStateClientProxyImpl
The default implementation of the
KvStateClientProxy . |
Modifier and Type | Method and Description |
---|---|
static KvStateClientProxy |
QueryableStateUtils.createKvStateClientProxy(String address,
Iterator<Integer> ports,
int eventLoopThreads,
int queryThreads,
KvStateRequestStats stats)
Initializes the
client proxy responsible for receiving requests
from the external (to the cluster) client and forwarding them internally. |
Modifier and Type | Method and Description |
---|---|
KvStateClientProxy |
KvStateService.getKvStateClientProxy() |
Constructor and Description |
---|
KvStateService(KvStateRegistry kvStateRegistry,
KvStateServer kvStateServer,
KvStateClientProxy kvStateClientProxy) |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.