Package | Description |
---|---|
org.apache.flink.contrib.streaming.state | |
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.
|
org.apache.flink.streaming.api.operators.sorted.state |
Modifier and Type | Method and Description |
---|---|
SavepointResources<K> |
RocksDBKeyedStateBackend.savepoint() |
Modifier and Type | Method and Description |
---|---|
SavepointResources<K> |
CheckpointableKeyedStateBackend.savepoint()
Returns a
SavepointResources that can be used by SavepointSnapshotStrategy to
write out a savepoint in the common/unified format. |
Modifier and Type | Method and Description |
---|---|
SavepointResources<K> |
HeapKeyedStateBackend.savepoint() |
Modifier and Type | Method and Description |
---|---|
SavepointResources<K> |
BatchExecutionKeyedStateBackend.savepoint() |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.