org.apache.flink.runtime.state

Interface SnapshotStrategy.SnapshotResultSupplier<S extends StateObject>

Type Parameters:

S - type of the returned state object that represents the result of the snapshot * operation.

All Known Implementing Classes:

FullSnapshotAsyncWriter, RocksDBSnapshotStrategyBase.RocksDBSnapshotOperation

Enclosing interface:

SnapshotStrategy<S extends StateObject,SR extends SnapshotResources>

Functional Interface:

This is a functional interface and can therefore be used as the assignment target for a lambda expression or method reference.

@FunctionalInterface
public static interface SnapshotStrategy.SnapshotResultSupplier<S extends StateObject>

A supplier for a SnapshotResult with an access to a CloseableRegistry for io tasks that need to be closed when cancelling the async part of the checkpoint.

Method Summary

Modifier and Type	Method and Description
SnapshotResult<S>	get(CloseableRegistry snapshotCloseableRegistry) Performs the asynchronous part of a checkpoint and returns the snapshot result.

Method Detail

get

SnapshotResult<S> get(CloseableRegistry snapshotCloseableRegistry)
               throws Exception

Performs the asynchronous part of a checkpoint and returns the snapshot result.

Parameters:

snapshotCloseableRegistry - A registry for io tasks to close on cancel.

Returns:

A snapshot result

Throws:

Exception