Uses of Class
org.apache.flink.runtime.checkpoint.CheckpointOptions

Packages that use CheckpointOptions

Package	Description
org.apache.flink.contrib.streaming.state
org.apache.flink.contrib.streaming.state.snapshot
org.apache.flink.runtime.asyncprocessing.operators
org.apache.flink.runtime.checkpoint
org.apache.flink.runtime.checkpoint.channel
org.apache.flink.runtime.executiongraph
org.apache.flink.runtime.io.network.api
org.apache.flink.runtime.jobgraph.tasks
org.apache.flink.runtime.jobmanager.slots
org.apache.flink.runtime.jobmaster
org.apache.flink.runtime.state
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.v2.adaptor
org.apache.flink.runtime.taskexecutor
org.apache.flink.runtime.taskmanager
org.apache.flink.state.api.output.operators
org.apache.flink.state.changelog
org.apache.flink.state.forst
org.apache.flink.state.forst.snapshot
org.apache.flink.state.forst.sync
org.apache.flink.streaming.api.operators
org.apache.flink.streaming.api.operators.sorted.state
org.apache.flink.streaming.runtime.tasks	This package contains classes that realize streaming tasks.

Uses of CheckpointOptions in org.apache.flink.contrib.streaming.state

Methods in org.apache.flink.contrib.streaming.state with parameters of type CheckpointOptions

Modifier and Type	Method	Description
RunnableFuture<SnapshotResult<KeyedStateHandle>>	RocksDBKeyedStateBackend.snapshot(long checkpointId, long timestamp, CheckpointStreamFactory streamFactory, CheckpointOptions checkpointOptions)	Triggers an asynchronous snapshot of the keyed state backend from RocksDB.

Uses of CheckpointOptions in org.apache.flink.contrib.streaming.state.snapshot

Methods in org.apache.flink.contrib.streaming.state.snapshot with parameters of type CheckpointOptions

Modifier and Type	Method	Description
SnapshotStrategy.SnapshotResultSupplier<KeyedStateHandle>	RocksIncrementalSnapshotStrategy.asyncSnapshot(RocksDBSnapshotStrategyBase.NativeRocksDBSnapshotResources snapshotResources, long checkpointId, long timestamp, CheckpointStreamFactory checkpointStreamFactory, CheckpointOptions checkpointOptions)
SnapshotStrategy.SnapshotResultSupplier<KeyedStateHandle>	RocksNativeFullSnapshotStrategy.asyncSnapshot(RocksDBSnapshotStrategyBase.NativeRocksDBSnapshotResources snapshotResources, long checkpointId, long timestamp, CheckpointStreamFactory checkpointStreamFactory, CheckpointOptions checkpointOptions)

Uses of CheckpointOptions in org.apache.flink.runtime.asyncprocessing.operators

Methods in org.apache.flink.runtime.asyncprocessing.operators with parameters of type CheckpointOptions

Modifier and Type	Method	Description
OperatorSnapshotFutures	AbstractAsyncStateStreamOperator.snapshotState(long checkpointId, long timestamp, CheckpointOptions checkpointOptions, CheckpointStreamFactory factory)
OperatorSnapshotFutures	AbstractAsyncStateStreamOperatorV2.snapshotState(long checkpointId, long timestamp, CheckpointOptions checkpointOptions, CheckpointStreamFactory factory)

Uses of CheckpointOptions in org.apache.flink.runtime.checkpoint

Methods in org.apache.flink.runtime.checkpoint that return CheckpointOptions

Modifier and Type	Method	Description
static CheckpointOptions	CheckpointOptions.alignedNoTimeout(SnapshotType type, CheckpointStorageLocationReference location)
static CheckpointOptions	CheckpointOptions.alignedWithTimeout(SnapshotType type, CheckpointStorageLocationReference location, long alignedCheckpointTimeout)
static CheckpointOptions	CheckpointOptions.forCheckpointWithDefaultLocation()
static CheckpointOptions	CheckpointOptions.forConfig(SnapshotType checkpointType, CheckpointStorageLocationReference locationReference, boolean isExactlyOnceMode, boolean isUnalignedEnabled, long alignedCheckpointTimeout)
static CheckpointOptions	CheckpointOptions.notExactlyOnce(SnapshotType type, CheckpointStorageLocationReference location)
CheckpointOptions	CheckpointOptions.toUnaligned()
static CheckpointOptions	CheckpointOptions.unaligned(SnapshotType type, CheckpointStorageLocationReference location)
CheckpointOptions	CheckpointOptions.withUnalignedSupported()
CheckpointOptions	CheckpointOptions.withUnalignedUnsupported()

Uses of CheckpointOptions in org.apache.flink.runtime.checkpoint.channel

Methods in org.apache.flink.runtime.checkpoint.channel with parameters of type CheckpointOptions

Modifier and Type	Method	Description
void	ChannelStateWriter.NoOpChannelStateWriter.start(long checkpointId, CheckpointOptions checkpointOptions)
void	ChannelStateWriter.start(long checkpointId, CheckpointOptions checkpointOptions)	Initiate write of channel state for the given checkpoint id.
void	ChannelStateWriterImpl.start(long checkpointId, CheckpointOptions checkpointOptions)

Uses of CheckpointOptions in org.apache.flink.runtime.executiongraph

Methods in org.apache.flink.runtime.executiongraph with parameters of type CheckpointOptions

Modifier and Type	Method	Description
CompletableFuture<Acknowledge>	Execution.triggerCheckpoint(long checkpointId, long timestamp, CheckpointOptions checkpointOptions)	Trigger a new checkpoint on the task of this execution.
CompletableFuture<Acknowledge>	Execution.triggerSynchronousSavepoint(long checkpointId, long timestamp, CheckpointOptions checkpointOptions)	Trigger a new checkpoint on the task of this execution.

Uses of CheckpointOptions in org.apache.flink.runtime.io.network.api

Methods in org.apache.flink.runtime.io.network.api that return CheckpointOptions

Modifier and Type	Method	Description
CheckpointOptions	CheckpointBarrier.getCheckpointOptions()

Methods in org.apache.flink.runtime.io.network.api with parameters of type CheckpointOptions

Modifier and Type	Method	Description
CheckpointBarrier	CheckpointBarrier.withOptions(CheckpointOptions checkpointOptions)

Constructors in org.apache.flink.runtime.io.network.api with parameters of type CheckpointOptions

Constructor	Description
CheckpointBarrier(long id, long timestamp, CheckpointOptions checkpointOptions)

Uses of CheckpointOptions in org.apache.flink.runtime.jobgraph.tasks

Methods in org.apache.flink.runtime.jobgraph.tasks with parameters of type CheckpointOptions

Modifier and Type	Method	Description
CompletableFuture<Boolean>	AbstractInvokable.triggerCheckpointAsync(CheckpointMetaData checkpointMetaData, CheckpointOptions checkpointOptions)
CompletableFuture<Boolean>	CheckpointableTask.triggerCheckpointAsync(CheckpointMetaData checkpointMetaData, CheckpointOptions checkpointOptions)	This method is called to trigger a checkpoint, asynchronously by the checkpoint coordinator.
void	AbstractInvokable.triggerCheckpointOnBarrier(CheckpointMetaData checkpointMetaData, CheckpointOptions checkpointOptions, CheckpointMetricsBuilder checkpointMetrics)
void	CheckpointableTask.triggerCheckpointOnBarrier(CheckpointMetaData checkpointMetaData, CheckpointOptions checkpointOptions, CheckpointMetricsBuilder checkpointMetrics)	This method is called when a checkpoint is triggered as a result of receiving checkpoint barriers on all input streams.

Uses of CheckpointOptions in org.apache.flink.runtime.jobmanager.slots

Methods in org.apache.flink.runtime.jobmanager.slots with parameters of type CheckpointOptions

Modifier and Type	Method	Description
CompletableFuture<Acknowledge>	TaskManagerGateway.triggerCheckpoint(ExecutionAttemptID executionAttemptID, JobID jobId, long checkpointId, long timestamp, CheckpointOptions checkpointOptions)	Trigger for the given task a checkpoint.

Uses of CheckpointOptions in org.apache.flink.runtime.jobmaster

Methods in org.apache.flink.runtime.jobmaster with parameters of type CheckpointOptions

Modifier and Type	Method	Description
CompletableFuture<Acknowledge>	RpcTaskManagerGateway.triggerCheckpoint(ExecutionAttemptID executionAttemptID, JobID jobId, long checkpointId, long timestamp, CheckpointOptions checkpointOptions)

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

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

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.
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)

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

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

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

Uses of CheckpointOptions in org.apache.flink.runtime.state.v2.adaptor

Methods in org.apache.flink.runtime.state.v2.adaptor with parameters of type CheckpointOptions

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

Uses of CheckpointOptions in org.apache.flink.runtime.taskexecutor

Methods in org.apache.flink.runtime.taskexecutor with parameters of type CheckpointOptions

Modifier and Type	Method	Description
CompletableFuture<Acknowledge>	TaskExecutor.triggerCheckpoint(ExecutionAttemptID executionAttemptID, long checkpointId, long checkpointTimestamp, CheckpointOptions checkpointOptions)
CompletableFuture<Acknowledge>	TaskExecutorGateway.triggerCheckpoint(ExecutionAttemptID executionAttemptID, long checkpointID, long checkpointTimestamp, CheckpointOptions checkpointOptions)	Trigger the checkpoint for the given task.
CompletableFuture<Acknowledge>	TaskExecutorGatewayDecoratorBase.triggerCheckpoint(ExecutionAttemptID executionAttemptID, long checkpointID, long checkpointTimestamp, CheckpointOptions checkpointOptions)

Uses of CheckpointOptions in org.apache.flink.runtime.taskmanager

Methods in org.apache.flink.runtime.taskmanager with parameters of type CheckpointOptions

Modifier and Type	Method	Description
void	Task.triggerCheckpointBarrier(long checkpointID, long checkpointTimestamp, CheckpointOptions checkpointOptions)	Calls the invokable to trigger a checkpoint.

Uses of CheckpointOptions in org.apache.flink.state.api.output.operators

Methods in org.apache.flink.state.api.output.operators with parameters of type CheckpointOptions

Modifier and Type	Method	Description
OperatorSnapshotFutures	StateBootstrapWrapperOperator.snapshotState(long checkpointId, long timestamp, CheckpointOptions checkpointOptions, CheckpointStreamFactory storageLocation)

Uses of CheckpointOptions in org.apache.flink.state.changelog

Methods in org.apache.flink.state.changelog with parameters of type CheckpointOptions

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

Uses of CheckpointOptions in org.apache.flink.state.forst

Methods in org.apache.flink.state.forst with parameters of type CheckpointOptions

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

Uses of CheckpointOptions in org.apache.flink.state.forst.snapshot

Methods in org.apache.flink.state.forst.snapshot with parameters of type CheckpointOptions

Modifier and Type	Method	Description
SnapshotStrategy.SnapshotResultSupplier<KeyedStateHandle>	ForStIncrementalSnapshotStrategy.asyncSnapshot(ForStSnapshotStrategyBase.ForStNativeSnapshotResources snapshotResources, long checkpointId, long timestamp, CheckpointStreamFactory checkpointStreamFactory, CheckpointOptions checkpointOptions)

Uses of CheckpointOptions in org.apache.flink.state.forst.sync

Methods in org.apache.flink.state.forst.sync with parameters of type CheckpointOptions

Modifier and Type	Method	Description
RunnableFuture<SnapshotResult<KeyedStateHandle>>	ForStSyncKeyedStateBackend.snapshot(long checkpointId, long timestamp, CheckpointStreamFactory streamFactory, CheckpointOptions checkpointOptions)	Triggers an asynchronous snapshot of the keyed state backend from RocksDB.

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

Methods in org.apache.flink.streaming.api.operators with parameters of type CheckpointOptions

Modifier and Type	Method	Description
OperatorSnapshotFutures	AbstractStreamOperator.snapshotState(long checkpointId, long timestamp, CheckpointOptions checkpointOptions, CheckpointStreamFactory factory)
OperatorSnapshotFutures	AbstractStreamOperatorV2.snapshotState(long checkpointId, long timestamp, CheckpointOptions checkpointOptions, CheckpointStreamFactory factory)
OperatorSnapshotFutures	StreamOperator.snapshotState(long checkpointId, long timestamp, CheckpointOptions checkpointOptions, CheckpointStreamFactory storageLocation)	Called to draw a state snapshot from the operator.
OperatorSnapshotFutures	StreamOperatorStateHandler.snapshotState(StreamOperatorStateHandler.CheckpointedStreamOperator streamOperator, Optional<InternalTimeServiceManager<?>> timeServiceManager, String operatorName, long checkpointId, long timestamp, CheckpointOptions checkpointOptions, CheckpointStreamFactory factory, boolean isUsingCustomRawKeyedState, boolean useAsyncState)

Uses of CheckpointOptions in org.apache.flink.streaming.api.operators.sorted.state

Methods in org.apache.flink.streaming.api.operators.sorted.state with parameters of type CheckpointOptions

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

Uses of CheckpointOptions in org.apache.flink.streaming.runtime.tasks

Methods in org.apache.flink.streaming.runtime.tasks with parameters of type CheckpointOptions

Modifier and Type	Method	Description
void	SubtaskCheckpointCoordinator.checkpointState(CheckpointMetaData checkpointMetaData, CheckpointOptions checkpointOptions, CheckpointMetricsBuilder checkpointMetrics, OperatorChain<?,?> operatorChain, boolean isTaskFinished, Supplier<Boolean> isRunning)	Must be called after SubtaskCheckpointCoordinator.initInputsCheckpoint(long, CheckpointOptions).
void	SubtaskCheckpointCoordinator.initInputsCheckpoint(long id, CheckpointOptions checkpointOptions)	Initialize new checkpoint.
void	FinishedOperatorChain.snapshotState(Map<OperatorID,OperatorSnapshotFutures> operatorSnapshotsInProgress, CheckpointMetaData checkpointMetaData, CheckpointOptions checkpointOptions, Supplier<Boolean> isRunning, ChannelStateWriter.ChannelStateWriteResult channelStateWriteResult, CheckpointStreamFactory storage)
abstract void	OperatorChain.snapshotState(Map<OperatorID,OperatorSnapshotFutures> operatorSnapshotsInProgress, CheckpointMetaData checkpointMetaData, CheckpointOptions checkpointOptions, Supplier<Boolean> isRunning, ChannelStateWriter.ChannelStateWriteResult channelStateWriteResult, CheckpointStreamFactory storage)
void	RegularOperatorChain.snapshotState(Map<OperatorID,OperatorSnapshotFutures> operatorSnapshotsInProgress, CheckpointMetaData checkpointMetaData, CheckpointOptions checkpointOptions, Supplier<Boolean> isRunning, ChannelStateWriter.ChannelStateWriteResult channelStateWriteResult, CheckpointStreamFactory storage)
CompletableFuture<Boolean>	MultipleInputStreamTask.triggerCheckpointAsync(CheckpointMetaData metadata, CheckpointOptions options)
CompletableFuture<Boolean>	SourceOperatorStreamTask.triggerCheckpointAsync(CheckpointMetaData checkpointMetaData, CheckpointOptions checkpointOptions)
CompletableFuture<Boolean>	SourceStreamTask.triggerCheckpointAsync(CheckpointMetaData checkpointMetaData, CheckpointOptions checkpointOptions)	Deprecated.
CompletableFuture<Boolean>	StreamTask.triggerCheckpointAsync(CheckpointMetaData checkpointMetaData, CheckpointOptions checkpointOptions)
void	MultipleInputStreamTask.triggerCheckpointOnBarrier(CheckpointMetaData checkpointMetaData, CheckpointOptions checkpointOptions, CheckpointMetricsBuilder checkpointMetrics)
void	StreamTask.triggerCheckpointOnBarrier(CheckpointMetaData checkpointMetaData, CheckpointOptions checkpointOptions, CheckpointMetricsBuilder checkpointMetrics)