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.
|
Modifier and Type | Interface and Description |
---|---|
interface |
RocksDBRestoreOperation
Interface for RocksDB restore.
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractRocksDBRestoreOperation<K>
Base implementation of RocksDB restore operation.
|
class |
RocksDBFullRestoreOperation<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.
|
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.