Package | Description |
---|---|
org.apache.flink.runtime.query.netty |
This package contains all Netty-based client/server classes used to query
KvState instances.
|
Modifier and Type | Class and Description |
---|---|
class |
AtomicKvStateRequestStats
Atomic
KvStateRequestStats implementation. |
class |
DisabledKvStateRequestStats
Disabled
KvStateRequestStats implementation. |
Constructor and Description |
---|
KvStateClient(int numEventLoopThreads,
KvStateRequestStats stats)
Creates a client with the specified number of event loop threads.
|
KvStateServer(InetAddress bindAddress,
int bindPort,
int numEventLoopThreads,
int numQueryThreads,
KvStateRegistry kvStateRegistry,
KvStateRequestStats stats)
Creates the
KvStateServer . |
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.