Package | Description |
---|---|
org.apache.flink.contrib.streaming.state.restore | |
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.runtime.state.restore | |
org.apache.flink.state.forst.restore |
Modifier and Type | Interface and Description |
---|---|
interface |
RocksDBRestoreOperation
Interface for RocksDB restore.
|
Modifier and Type | Class and Description |
---|---|
class |
RocksDBFullRestoreOperation<K>
Encapsulates the process of restoring a RocksDB instance from a full snapshot.
|
class |
RocksDBHeapTimersFullRestoreOperation<K>
Encapsulates the process of restoring a RocksDB instance from a full snapshot.
|
class |
RocksDBIncrementalRestoreOperation<K>
Encapsulates the process of restoring a RocksDB instance from an incremental snapshot.
|
class |
RocksDBNoneRestoreOperation<K>
Encapsulates the process of initiating a RocksDB instance without restore.
|
Modifier and Type | Class and Description |
---|---|
class |
OperatorStateRestoreOperation
Implementation of operator state restore operation.
|
Modifier and Type | Class and Description |
---|---|
class |
HeapRestoreOperation<K>
Implementation of heap restore operation.
|
class |
HeapSavepointRestoreOperation<K>
Implementation of heap savepoint restore operation.
|
Modifier and Type | Class and Description |
---|---|
class |
FullSnapshotRestoreOperation<K>
The procedure of restoring state from a savepoint written with the unified binary format.
|
Modifier and Type | Interface and Description |
---|---|
interface |
ForStRestoreOperation
Interface for ForSt restore.
|
Modifier and Type | Class and Description |
---|---|
class |
ForStNoneRestoreOperation
Encapsulates the process of initiating a ForSt instance without restore.
|
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.