Package | Description |
---|---|
org.apache.flink.contrib.streaming.state.iterator | |
org.apache.flink.contrib.streaming.state.snapshot | |
org.apache.flink.runtime.state | |
org.apache.flink.runtime.state.heap |
This package contains the classes for key/value state backends that store the state on the JVM
heap as objects.
|
Modifier and Type | Class and Description |
---|---|
class |
RocksStatesPerKeyGroupMergeIterator
Iterator that merges multiple RocksDB iterators to partition all states into contiguous
key-groups.
|
Modifier and Type | Method and Description |
---|---|
KeyValueStateIterator |
RocksDBFullSnapshotResources.createKVStateIterator() |
Modifier and Type | Method and Description |
---|---|
KeyValueStateIterator |
FullSnapshotResources.createKVStateIterator()
Returns a
KeyValueStateIterator for iterating over all key-value states for this
snapshot resources. |
Modifier and Type | Class and Description |
---|---|
class |
HeapKeyValueStateIterator
A
KeyValueStateIterator over Heap backend snapshot
resources. |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.