Package | Description |
---|---|
org.apache.flink.runtime.io.network | |
org.apache.flink.runtime.query.netty |
This package contains all Netty-based client/server classes used to query
KvState instances.
|
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,
IOManager.IOMode defaultIOMode,
int partitionRequestInitialBackoff,
int partitionRequestMaxBackoff) |
Constructor and Description |
---|
KvStateServer(InetAddress bindAddress,
int bindPort,
int numEventLoopThreads,
int numQueryThreads,
KvStateRegistry kvStateRegistry,
KvStateRequestStats stats)
Creates the
KvStateServer . |
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.