Uses of Class
org.apache.flink.streaming.api.operators.OperatorSnapshotFutures

Packages that use OperatorSnapshotFutures

Package	Description
org.apache.flink.state.api.output.operators
org.apache.flink.streaming.api.operators
org.apache.flink.streaming.runtime.operators.asyncprocessing
org.apache.flink.streaming.runtime.tasks	This package contains classes that realize streaming tasks.

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

Methods in org.apache.flink.state.api.output.operators that return OperatorSnapshotFutures

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

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

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

Modifier and Type	Method and Description
OperatorSnapshotFutures	AbstractStreamOperator.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	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)

Constructors in org.apache.flink.streaming.api.operators with parameters of type OperatorSnapshotFutures

Constructor and Description
OperatorSnapshotFinalizer(OperatorSnapshotFutures snapshotFutures)

Uses of OperatorSnapshotFutures in org.apache.flink.streaming.runtime.operators.asyncprocessing

Methods in org.apache.flink.streaming.runtime.operators.asyncprocessing that return OperatorSnapshotFutures

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

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

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

Modifier and Type	Method and Description
protected void	OperatorChain.snapshotChannelStates(StreamOperator<?> op, ChannelStateWriter.ChannelStateWriteResult channelStateWriteResult, OperatorSnapshotFutures snapshotInProgress)

Method parameters in org.apache.flink.streaming.runtime.tasks with type arguments of type OperatorSnapshotFutures

Modifier and Type	Method and Description
void	RegularOperatorChain.snapshotState(Map<OperatorID,OperatorSnapshotFutures> operatorSnapshotsInProgress, CheckpointMetaData checkpointMetaData, CheckpointOptions checkpointOptions, Supplier<Boolean> isRunning, ChannelStateWriter.ChannelStateWriteResult channelStateWriteResult, CheckpointStreamFactory storage)
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)