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.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.taskexecutor
org.apache.flink.runtime.taskmanager
org.apache.flink.state.api.output.operators
org.apache.flink.streaming.api.operators
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 and 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 and Description
RunnableFuture<SnapshotResult<KeyedStateHandle>>	RocksFullSnapshotStrategy.doSnapshot(long checkpointId, long timestamp, CheckpointStreamFactory primaryStreamFactory, CheckpointOptions checkpointOptions)
protected RunnableFuture<SnapshotResult<KeyedStateHandle>>	RocksIncrementalSnapshotStrategy.doSnapshot(long checkpointId, long checkpointTimestamp, CheckpointStreamFactory checkpointStreamFactory, CheckpointOptions checkpointOptions)
protected abstract RunnableFuture<SnapshotResult<KeyedStateHandle>>	RocksDBSnapshotStrategyBase.doSnapshot(long checkpointId, long timestamp, CheckpointStreamFactory streamFactory, CheckpointOptions checkpointOptions) This method implements the concrete snapshot logic for a non-empty state.
RunnableFuture<SnapshotResult<KeyedStateHandle>>	RocksDBSnapshotStrategyBase.snapshot(long checkpointId, long timestamp, CheckpointStreamFactory streamFactory, CheckpointOptions checkpointOptions)

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

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

Modifier and Type	Method and Description
static CheckpointOptions	CheckpointOptions.alignedNoTimeout(CheckpointType type, CheckpointStorageLocationReference location)
static CheckpointOptions	CheckpointOptions.alignedWithTimeout(CheckpointStorageLocationReference location, long alignmentTimeout)
static CheckpointOptions	CheckpointOptions.create(CheckpointType checkpointType, CheckpointStorageLocationReference locationReference, boolean isExactlyOnceMode, boolean unalignedCheckpointsEnabled, long alignmentTimeout)
static CheckpointOptions	CheckpointOptions.forCheckpointWithDefaultLocation()
static CheckpointOptions	CheckpointOptions.forConfig(CheckpointType checkpointType, CheckpointStorageLocationReference locationReference, boolean isExactlyOnceMode, boolean isUnalignedEnabled, long alignmentTimeout)
static CheckpointOptions	CheckpointOptions.notExactlyOnce(CheckpointType type, CheckpointStorageLocationReference location)
CheckpointOptions	CheckpointOptions.toUnaligned()
static CheckpointOptions	CheckpointOptions.unaligned(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 and Description
void	ChannelStateWriterImpl.start(long checkpointId, CheckpointOptions checkpointOptions)
void	ChannelStateWriter.start(long checkpointId, CheckpointOptions checkpointOptions) Initiate write of channel state for the given checkpoint id.
void	ChannelStateWriter.NoOpChannelStateWriter.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 and Description
void	Execution.triggerCheckpoint(long checkpointId, long timestamp, CheckpointOptions checkpointOptions) Trigger a new checkpoint on the task of this execution.
void	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 and Description
CheckpointOptions	CheckpointBarrier.getCheckpointOptions()

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

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

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

Constructor and 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 and Description
Future<Boolean>	AbstractInvokable.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) 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 and Description
void	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 and Description
void	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 and Description
RunnableFuture<S>	SnapshotStrategy.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<OperatorStateHandle>>	DefaultOperatorStateBackend.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 and Description
RunnableFuture<SnapshotResult<KeyedStateHandle>>	HeapKeyedStateBackend.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 and Description
CompletableFuture<Acknowledge>	TaskExecutor.triggerCheckpoint(ExecutionAttemptID executionAttemptID, long checkpointId, long checkpointTimestamp, CheckpointOptions checkpointOptions)
CompletableFuture<Acknowledge>	TaskExecutorGatewayDecoratorBase.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.

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 and 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 and Description
OperatorSnapshotFutures	StateBootstrapWrapperOperator.snapshotState(long checkpointId, long timestamp, CheckpointOptions checkpointOptions, CheckpointStreamFactory storageLocation)

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

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 and Description
void	SubtaskCheckpointCoordinator.checkpointState(CheckpointMetaData checkpointMetaData, CheckpointOptions checkpointOptions, CheckpointMetricsBuilder checkpointMetrics, OperatorChain<?,?> operatorChain, java.util.function.Supplier<Boolean> isRunning) Must be called after SubtaskCheckpointCoordinator.initCheckpoint(long, CheckpointOptions).
void	SubtaskCheckpointCoordinator.initCheckpoint(long id, CheckpointOptions checkpointOptions) Initialize new checkpoint.
Future<Boolean>	StreamTask.triggerCheckpointAsync(CheckpointMetaData checkpointMetaData, CheckpointOptions checkpointOptions)
Future<Boolean>	SourceStreamTask.triggerCheckpointAsync(CheckpointMetaData checkpointMetaData, CheckpointOptions checkpointOptions)
Future<Boolean>	SourceOperatorStreamTask.triggerCheckpointAsync(CheckpointMetaData checkpointMetaData, CheckpointOptions checkpointOptions)
Future<Boolean>	MultipleInputStreamTask.triggerCheckpointAsync(CheckpointMetaData metadata, CheckpointOptions options)
void	StreamTask.triggerCheckpointOnBarrier(CheckpointMetaData checkpointMetaData, CheckpointOptions checkpointOptions, CheckpointMetricsBuilder checkpointMetrics)
void	MultipleInputStreamTask.triggerCheckpointOnBarrier(CheckpointMetaData checkpointMetaData, CheckpointOptions checkpointOptions, CheckpointMetricsBuilder checkpointMetrics)