Uses of Class
org.apache.flink.runtime.checkpoint.channel.ChannelStateWriter.ChannelStateWriteResult

Packages that use ChannelStateWriter.ChannelStateWriteResult

Package	Description
org.apache.flink.runtime.checkpoint.channel
org.apache.flink.streaming.runtime.tasks	This package contains classes that realize streaming tasks.

Uses of ChannelStateWriter.ChannelStateWriteResult in org.apache.flink.runtime.checkpoint.channel

Fields in org.apache.flink.runtime.checkpoint.channel declared as ChannelStateWriter.ChannelStateWriteResult

Modifier and Type	Field and Description
static ChannelStateWriter.ChannelStateWriteResult	ChannelStateWriter.ChannelStateWriteResult.EMPTY

Methods in org.apache.flink.runtime.checkpoint.channel that return ChannelStateWriter.ChannelStateWriteResult

Modifier and Type	Method and Description
ChannelStateWriter.ChannelStateWriteResult	ChannelStateWriter.getAndRemoveWriteResult(long checkpointId) Must be called after ChannelStateWriter.start(long, CheckpointOptions) once.
ChannelStateWriter.ChannelStateWriteResult	ChannelStateWriter.NoOpChannelStateWriter.getAndRemoveWriteResult(long checkpointId)
ChannelStateWriter.ChannelStateWriteResult	ChannelStateWriterImpl.getAndRemoveWriteResult(long checkpointId)
ChannelStateWriter.ChannelStateWriteResult	ChannelStateWriterImpl.getWriteResult(long checkpointId)

Constructors in org.apache.flink.runtime.checkpoint.channel with parameters of type ChannelStateWriter.ChannelStateWriteResult

Constructor and Description
ChannelStatePendingResult(int subtaskIndex, long checkpointId, ChannelStateWriter.ChannelStateWriteResult result, org.apache.flink.runtime.checkpoint.channel.ChannelStateSerializer serializer)

Uses of ChannelStateWriter.ChannelStateWriteResult in org.apache.flink.streaming.runtime.tasks

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

Modifier and Type	Method and Description
protected void	OperatorChain.snapshotChannelStates(StreamOperator<?> op, ChannelStateWriter.ChannelStateWriteResult channelStateWriteResult, OperatorSnapshotFutures snapshotInProgress)
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)
void	FinishedOperatorChain.snapshotState(Map<OperatorID,OperatorSnapshotFutures> operatorSnapshotsInProgress, CheckpointMetaData checkpointMetaData, CheckpointOptions checkpointOptions, Supplier<Boolean> isRunning, ChannelStateWriter.ChannelStateWriteResult channelStateWriteResult, CheckpointStreamFactory storage)