Package | Description |
---|---|
org.apache.flink.queryablestate.server | |
org.apache.flink.runtime.query | |
org.apache.flink.runtime.taskexecutor |
Constructor and Description |
---|
KvStateServerHandler(KvStateServerImpl server,
KvStateRegistry kvStateRegistry,
MessageSerializer<KvStateInternalRequest,KvStateResponse> serializer,
KvStateRequestStats stats)
Create the handler used by the
KvStateServerImpl . |
KvStateServerImpl(String bindAddress,
Iterator<Integer> bindPortIterator,
Integer numEventLoopThreads,
Integer numQueryThreads,
KvStateRegistry kvStateRegistry,
KvStateRequestStats stats)
Creates the state server.
|
Modifier and Type | Method and Description |
---|---|
static KvStateServer |
QueryableStateUtils.createKvStateServer(String address,
Iterator<Integer> ports,
int eventLoopThreads,
int queryThreads,
KvStateRegistry kvStateRegistry,
KvStateRequestStats stats)
Initializes the
server responsible for sending the requested internal
state to the client proxy . |
Modifier and Type | Method and Description |
---|---|
KvStateRegistry |
KvStateService.getKvStateRegistry() |
Constructor and Description |
---|
KvStateService(KvStateRegistry kvStateRegistry,
KvStateServer kvStateServer,
KvStateClientProxy kvStateClientProxy) |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.