Uses of Interface
org.apache.flink.runtime.state.CheckpointStreamFactory

Packages that use CheckpointStreamFactory

Package	Description
org.apache.flink.runtime.state
org.apache.flink.runtime.state.filesystem
org.apache.flink.runtime.state.heap	This package contains the classes for key/value state backends that store the state on the JVM heap as objects.
org.apache.flink.runtime.state.memory

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

Subinterfaces of CheckpointStreamFactory in org.apache.flink.runtime.state

Modifier and Type	Interface	Description
interface	CheckpointStorageLocation	A storage location for one particular checkpoint, offering data persistent, metadata persistence, and lifecycle/cleanup methods.

Methods in org.apache.flink.runtime.state that return CheckpointStreamFactory

Modifier and Type	Method	Description
CheckpointStreamFactory	CheckpointStorageWorkerView.resolveCheckpointStorageLocation(long checkpointId, CheckpointStorageLocationReference reference)	Resolves a storage location reference into a CheckpointStreamFactory.

Methods in org.apache.flink.runtime.state with parameters of type CheckpointStreamFactory

Modifier and Type	Method	Description
SnapshotStrategy.SnapshotResultSupplier<KeyedStateHandle>	SavepointSnapshotStrategy.asyncSnapshot(FullSnapshotResources<K> savepointResources, long checkpointId, long timestamp, CheckpointStreamFactory streamFactory, CheckpointOptions checkpointOptions)
SnapshotStrategy.SnapshotResultSupplier<S>	SnapshotStrategy.asyncSnapshot(SR syncPartResource, long checkpointId, long timestamp, CheckpointStreamFactory streamFactory, CheckpointOptions checkpointOptions)	Operation that writes a snapshot into a stream that is provided by the given CheckpointStreamFactory and returns a @SupplierWithException that gives a state handle to the snapshot.
static CheckpointStreamWithResultProvider	CheckpointStreamWithResultProvider.createDuplicatingStream(long checkpointId, CheckpointedStateScope checkpointedStateScope, CheckpointStreamFactory primaryStreamFactory, LocalRecoveryDirectoryProvider secondaryStreamDirProvider)
static CheckpointStreamWithResultProvider	CheckpointStreamWithResultProvider.createSimpleStream(CheckpointedStateScope checkpointedStateScope, CheckpointStreamFactory primaryStreamFactory)
RunnableFuture<SnapshotResult<OperatorStateHandle>>	DefaultOperatorStateBackend.snapshot(long checkpointId, long timestamp, CheckpointStreamFactory streamFactory, CheckpointOptions checkpointOptions)
RunnableFuture<S>	Snapshotable.snapshot(long checkpointId, long timestamp, CheckpointStreamFactory streamFactory, CheckpointOptions checkpointOptions)	Operation that writes a snapshot into a stream that is provided by the given CheckpointStreamFactory and returns a @RunnableFuture that gives a state handle to the snapshot.
RunnableFuture<SnapshotResult<T>>	SnapshotStrategyRunner.snapshot(long checkpointId, long timestamp, CheckpointStreamFactory streamFactory, CheckpointOptions checkpointOptions)

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

Constructor	Description
StateSnapshotContextSynchronousImpl(long checkpointId, long checkpointTimestamp, CheckpointStreamFactory streamFactory, KeyGroupRange keyGroupRange, org.apache.flink.core.fs.CloseableRegistry closableRegistry)

Uses of CheckpointStreamFactory in org.apache.flink.runtime.state.filesystem

Classes in org.apache.flink.runtime.state.filesystem that implement CheckpointStreamFactory

Modifier and Type	Class	Description
class	FsCheckpointStorageLocation	A storage location for checkpoints on a file system.
class	FsCheckpointStreamFactory	A CheckpointStreamFactory that produces streams that write to a FileSystem.

Methods in org.apache.flink.runtime.state.filesystem that return CheckpointStreamFactory

Modifier and Type	Method	Description
CheckpointStreamFactory	FsCheckpointStorageAccess.resolveCheckpointStorageLocation(long checkpointId, CheckpointStorageLocationReference reference)

Uses of CheckpointStreamFactory in org.apache.flink.runtime.state.heap

Methods in org.apache.flink.runtime.state.heap with parameters of type CheckpointStreamFactory

Modifier and Type	Method	Description
RunnableFuture<SnapshotResult<KeyedStateHandle>>	HeapKeyedStateBackend.snapshot(long checkpointId, long timestamp, CheckpointStreamFactory streamFactory, CheckpointOptions checkpointOptions)

Uses of CheckpointStreamFactory in org.apache.flink.runtime.state.memory

Classes in org.apache.flink.runtime.state.memory that implement CheckpointStreamFactory

Modifier and Type	Class	Description
class	MemCheckpointStreamFactory	CheckpointStreamFactory that produces streams that write to in-memory byte arrays.
class	NonPersistentMetadataCheckpointStorageLocation	A checkpoint storage location for the MemoryStateBackend in case no durable persistence for metadata has been configured.
class	PersistentMetadataCheckpointStorageLocation	A checkpoint storage location for the MemoryStateBackend when it durably persists the metadata in a file system.

Methods in org.apache.flink.runtime.state.memory that return CheckpointStreamFactory

Modifier and Type	Method	Description
CheckpointStreamFactory	MemoryBackendCheckpointStorageAccess.resolveCheckpointStorageLocation(long checkpointId, CheckpointStorageLocationReference reference)