Package | Description |
---|---|
org.apache.flink.contrib.streaming.state |
Modifier and Type | Class and Description |
---|---|
class |
RocksDBAggregatingState<K,N,T,ACC,R>
An
AggregatingState implementation that stores state in RocksDB. |
class |
RocksDBFoldingState<K,N,T,ACC>
Deprecated.
will be removed in a future version
|
class |
RocksDBListState<K,N,V>
ListState implementation that stores state in RocksDB. |
class |
RocksDBMapState<K,N,UK,UV>
MapState implementation that stores state in RocksDB. |
class |
RocksDBReducingState<K,N,V>
ReducingState implementation that stores state in RocksDB. |
class |
RocksDBValueState<K,N,V>
ValueState implementation that stores state in RocksDB. |
Copyright © 2014–2019 The Apache Software Foundation. All rights reserved.