org.apache.flink.runtime.state

Class SnapshotStrategyRunner<T extends StateObject,SR extends SnapshotResources>

java.lang.Object

org.apache.flink.runtime.state.SnapshotStrategyRunner<T,SR>

Type Parameters:

T - type of the snapshot result.

public final class SnapshotStrategyRunner<T extends StateObject,SR extends SnapshotResources>
extends Object

A class to execute a SnapshotStrategy. It can execute a strategy either synchronously or asynchronously. It takes care of common logging and resource cleaning.

Constructor Summary

Constructors

Constructor and Description
SnapshotStrategyRunner(String description, SnapshotStrategy<T,SR> snapshotStrategy, CloseableRegistry cancelStreamRegistry, SnapshotExecutionType executionType)

Method Summary

Modifier and Type	Method and Description
RunnableFuture<SnapshotResult<T>>	snapshot(long checkpointId, long timestamp, CheckpointStreamFactory streamFactory, CheckpointOptions checkpointOptions)
String	toString()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

SnapshotStrategyRunner

public SnapshotStrategyRunner(@Nonnull
                              String description,
                              @Nonnull
                              SnapshotStrategy<T,SR> snapshotStrategy,
                              @Nonnull
                              CloseableRegistry cancelStreamRegistry,
                              @Nonnull
                              SnapshotExecutionType executionType)

Method Detail

snapshot

@Nonnull
public final RunnableFuture<SnapshotResult<T>> snapshot(long checkpointId,
                                                                 long timestamp,
                                                                 @Nonnull
                                                                 CheckpointStreamFactory streamFactory,
                                                                 @Nonnull
                                                                 CheckpointOptions checkpointOptions)
                                                          throws Exception

Throws:

Exception

toString

public String toString()

Overrides:

toString in class Object