Package | Description |
---|---|
org.apache.flink.contrib.streaming.state.snapshot | |
org.apache.flink.runtime.state |
Modifier and Type | Class and Description |
---|---|
protected class |
RocksDBSnapshotStrategyBase.RocksDBSnapshotOperation
Common operation in native rocksdb snapshot result supplier.
|
Modifier and Type | Method and Description |
---|---|
SnapshotStrategy.SnapshotResultSupplier<KeyedStateHandle> |
RocksIncrementalSnapshotStrategy.asyncSnapshot(RocksDBSnapshotStrategyBase.NativeRocksDBSnapshotResources snapshotResources,
long checkpointId,
long timestamp,
CheckpointStreamFactory checkpointStreamFactory,
CheckpointOptions checkpointOptions) |
SnapshotStrategy.SnapshotResultSupplier<KeyedStateHandle> |
RocksNativeFullSnapshotStrategy.asyncSnapshot(RocksDBSnapshotStrategyBase.NativeRocksDBSnapshotResources snapshotResources,
long checkpointId,
long timestamp,
CheckpointStreamFactory checkpointStreamFactory,
CheckpointOptions checkpointOptions) |
Modifier and Type | Class and Description |
---|---|
class |
FullSnapshotAsyncWriter<K>
An asynchronous writer that can write a full snapshot/savepoint from a
FullSnapshotResources . |
Modifier and Type | Method and Description |
---|---|
SnapshotStrategy.SnapshotResultSupplier<KeyedStateHandle> |
SavepointSnapshotStrategy.asyncSnapshot(FullSnapshotResources<K> savepointResources,
long checkpointId,
long timestamp,
CheckpointStreamFactory streamFactory,
CheckpointOptions checkpointOptions) |
SnapshotStrategy.SnapshotResultSupplier<S> |
SnapshotStrategy.asyncSnapshot(SR syncPartResource,
long checkpointId,
long timestamp,
CheckpointStreamFactory streamFactory,
CheckpointOptions checkpointOptions)
Operation that writes a snapshot into a stream that is provided by the given
CheckpointStreamFactory and returns a @SupplierWithException that gives a state
handle to the snapshot. |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.