Package org.apache.flink.runtime.state
Class FullSnapshotAsyncWriter<K>
- java.lang.Object
-
- org.apache.flink.runtime.state.FullSnapshotAsyncWriter<K>
-
- Type Parameters:
K
- type of the backend keys.
- All Implemented Interfaces:
SnapshotStrategy.SnapshotResultSupplier<KeyedStateHandle>
public class FullSnapshotAsyncWriter<K> extends Object implements SnapshotStrategy.SnapshotResultSupplier<KeyedStateHandle>
An asynchronous writer that can write a full snapshot/savepoint from aFullSnapshotResources
.
-
-
Constructor Summary
Constructors Constructor Description FullSnapshotAsyncWriter(SnapshotType snapshotType, SupplierWithException<CheckpointStreamWithResultProvider,Exception> checkpointStreamSupplier, FullSnapshotResources<K> snapshotResources)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description SnapshotResult<KeyedStateHandle>
get(CloseableRegistry snapshotCloseableRegistry)
Performs the asynchronous part of a checkpoint and returns the snapshot result.
-
-
-
Constructor Detail
-
FullSnapshotAsyncWriter
public FullSnapshotAsyncWriter(@Nonnull SnapshotType snapshotType, @Nonnull SupplierWithException<CheckpointStreamWithResultProvider,Exception> checkpointStreamSupplier, @Nonnull FullSnapshotResources<K> snapshotResources)
-
-
Method Detail
-
get
public SnapshotResult<KeyedStateHandle> get(CloseableRegistry snapshotCloseableRegistry) throws Exception
Description copied from interface:SnapshotStrategy.SnapshotResultSupplier
Performs the asynchronous part of a checkpoint and returns the snapshot result.- Specified by:
get
in interfaceSnapshotStrategy.SnapshotResultSupplier<K>
- Parameters:
snapshotCloseableRegistry
- A registry for io tasks to close on cancel.- Returns:
- A snapshot result
- Throws:
Exception
-
-