T
- type of the snapshot result.public final class SnapshotStrategyRunner<T extends StateObject,SR extends SnapshotResources> extends Object
SnapshotStrategy
. It can execute a strategy either synchronously or
asynchronously. It takes care of common logging and resource cleaning.Constructor and Description |
---|
SnapshotStrategyRunner(String description,
SnapshotStrategy<T,SR> snapshotStrategy,
CloseableRegistry cancelStreamRegistry,
SnapshotExecutionType executionType) |
Modifier and Type | Method and Description |
---|---|
RunnableFuture<SnapshotResult<T>> |
snapshot(long checkpointId,
long timestamp,
CheckpointStreamFactory streamFactory,
CheckpointOptions checkpointOptions) |
String |
toString() |
public SnapshotStrategyRunner(@Nonnull String description, @Nonnull SnapshotStrategy<T,SR> snapshotStrategy, @Nonnull CloseableRegistry cancelStreamRegistry, @Nonnull SnapshotExecutionType executionType)
@Nonnull public final RunnableFuture<SnapshotResult<T>> snapshot(long checkpointId, long timestamp, @Nonnull CheckpointStreamFactory streamFactory, @Nonnull CheckpointOptions checkpointOptions) throws Exception
Exception
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.