Package | Description |
---|---|
org.apache.flink.queryablestate.server | |
org.apache.flink.runtime.io.network | |
org.apache.flink.runtime.query |
Constructor and Description |
---|
KvStateServerHandler(KvStateServerImpl server,
KvStateRegistry kvStateRegistry,
MessageSerializer<KvStateInternalRequest,KvStateResponse> serializer,
KvStateRequestStats stats)
Create the handler used by the
KvStateServerImpl . |
KvStateServerImpl(InetAddress bindAddress,
Iterator<Integer> bindPortIterator,
Integer numEventLoopThreads,
Integer numQueryThreads,
KvStateRegistry kvStateRegistry,
KvStateRequestStats stats)
Creates the state server.
|
Modifier and Type | Method and Description |
---|---|
KvStateRegistry |
NetworkEnvironment.getKvStateRegistry() |
Constructor and Description |
---|
NetworkEnvironment(NetworkBufferPool networkBufferPool,
ConnectionManager connectionManager,
ResultPartitionManager resultPartitionManager,
TaskEventDispatcher taskEventDispatcher,
KvStateRegistry kvStateRegistry,
KvStateServer kvStateServer,
KvStateClientProxy kvStateClientProxy,
IOManager.IOMode defaultIOMode,
int partitionRequestInitialBackoff,
int partitionRequestMaxBackoff,
int networkBuffersPerChannel,
int extraNetworkBuffersPerGate,
boolean enableCreditBased) |
Modifier and Type | Method and Description |
---|---|
static KvStateServer |
QueryableStateUtils.createKvStateServer(InetAddress 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 . |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.