Uses of Class
org.apache.flink.runtime.state.SnapshotStrategyRunner

Packages that use SnapshotStrategyRunner

Package	Description
org.apache.flink.runtime.state
org.apache.flink.streaming.api.operators

Uses of SnapshotStrategyRunner in org.apache.flink.runtime.state

Constructors in org.apache.flink.runtime.state with parameters of type SnapshotStrategyRunner

Constructor and Description

DefaultOperatorStateBackend(ExecutionConfig executionConfig, CloseableRegistry closeStreamOnCancelRegistry, Map<String,PartitionableListState<?>> registeredOperatorStates, Map<String,BackendWritableBroadcastState<?,?>> registeredBroadcastStates, Map<String,PartitionableListState<?>> accessedStatesByName, Map<String,BackendWritableBroadcastState<?,?>> accessedBroadcastStatesByName, SnapshotStrategyRunner<OperatorStateHandle,?> snapshotStrategyRunner)

Uses of SnapshotStrategyRunner in org.apache.flink.streaming.api.operators

Methods in org.apache.flink.streaming.api.operators that return SnapshotStrategyRunner

Modifier and Type	Method and Description
static SnapshotStrategyRunner<KeyedStateHandle,? extends FullSnapshotResources<?>>	StreamOperatorStateHandler.prepareCanonicalSavepoint(CheckpointableKeyedStateBackend<?> keyedStateBackend, CloseableRegistry closeableRegistry)