Uses of Interface
org.apache.flink.runtime.checkpoint.channel.ChannelStateWriter

Packages that use ChannelStateWriter

Package	Description
org.apache.flink.runtime.checkpoint.channel
org.apache.flink.runtime.io.network.partition
org.apache.flink.runtime.io.network.partition.consumer
org.apache.flink.runtime.taskmanager
org.apache.flink.streaming.api.operators.sort
org.apache.flink.streaming.runtime.io
org.apache.flink.streaming.runtime.io.recovery
org.apache.flink.streaming.runtime.tasks	This package contains classes that realize streaming tasks.

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

Classes in org.apache.flink.runtime.checkpoint.channel that implement ChannelStateWriter

Modifier and Type	Class and Description
static class	ChannelStateWriter.NoOpChannelStateWriter No-op implementation of ChannelStateWriter.
class	ChannelStateWriterImpl ChannelStateWriter implemented using CheckpointStateOutputStreams.

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

Modifier and Type	Field and Description
static ChannelStateWriter	ChannelStateWriter.NO_OP

Uses of ChannelStateWriter in org.apache.flink.runtime.io.network.partition

Methods in org.apache.flink.runtime.io.network.partition with parameters of type ChannelStateWriter

Modifier and Type	Method and Description
void	ChannelStateHolder.setChannelStateWriter(ChannelStateWriter channelStateWriter) Injects the ChannelStateWriter.
void	PipelinedResultPartition.setChannelStateWriter(ChannelStateWriter channelStateWriter)
void	PipelinedSubpartition.setChannelStateWriter(ChannelStateWriter channelStateWriter)

Uses of ChannelStateWriter in org.apache.flink.runtime.io.network.partition.consumer

Fields in org.apache.flink.runtime.io.network.partition.consumer declared as ChannelStateWriter

Modifier and Type	Field and Description
protected ChannelStateWriter	RecoveredInputChannel.channelStateWriter

Methods in org.apache.flink.runtime.io.network.partition.consumer with parameters of type ChannelStateWriter

Modifier and Type	Method and Description
void	InputGate.setChannelStateWriter(ChannelStateWriter channelStateWriter)
void	RecoveredInputChannel.setChannelStateWriter(ChannelStateWriter channelStateWriter)

Constructors in org.apache.flink.runtime.io.network.partition.consumer with parameters of type ChannelStateWriter

Constructor and Description
LocalInputChannel(SingleInputGate inputGate, int channelIndex, ResultPartitionID partitionId, int consumedSubpartitionIndex, ResultPartitionManager partitionManager, TaskEventPublisher taskEventPublisher, int initialBackoff, int maxBackoff, Counter numBytesIn, Counter numBuffersIn, ChannelStateWriter stateWriter)
RemoteInputChannel(SingleInputGate inputGate, int channelIndex, ResultPartitionID partitionId, int consumedSubpartitionIndex, ConnectionID connectionId, ConnectionManager connectionManager, int initialBackOff, int maxBackoff, int networkBuffersPerChannel, Counter numBytesIn, Counter numBuffersIn, ChannelStateWriter stateWriter)

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

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

Modifier and Type	Method and Description
void	InputGateWithMetrics.setChannelStateWriter(ChannelStateWriter channelStateWriter)

Uses of ChannelStateWriter in org.apache.flink.streaming.api.operators.sort

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

Modifier and Type	Method and Description
CompletableFuture<Void>	MultiInputSortingDataInput.prepareSnapshot(ChannelStateWriter channelStateWriter, long checkpointId)
CompletableFuture<Void>	SortingDataInput.prepareSnapshot(ChannelStateWriter channelStateWriter, long checkpointId)

Uses of ChannelStateWriter in org.apache.flink.streaming.runtime.io

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

Modifier and Type	Method and Description
CompletableFuture<Void>	StreamTaskInput.prepareSnapshot(ChannelStateWriter channelStateWriter, long checkpointId) Prepares to spill the in-flight input buffers as checkpoint snapshot.
CompletableFuture<Void>	StreamOneInputProcessor.prepareSnapshot(ChannelStateWriter channelStateWriter, long checkpointId)
CompletableFuture<Void>	StreamTaskNetworkInput.prepareSnapshot(ChannelStateWriter channelStateWriter, long checkpointId)
CompletableFuture<Void>	StreamTaskSourceInput.prepareSnapshot(ChannelStateWriter channelStateWriter, long checkpointId)
CompletableFuture<Void>	StreamInputProcessor.prepareSnapshot(ChannelStateWriter channelStateWriter, long checkpointId)
CompletableFuture<Void>	StreamMultipleInputProcessor.prepareSnapshot(ChannelStateWriter channelStateWriter, long checkpointId)

Uses of ChannelStateWriter in org.apache.flink.streaming.runtime.io.recovery

Methods in org.apache.flink.streaming.runtime.io.recovery with parameters of type ChannelStateWriter

Modifier and Type	Method and Description
CompletableFuture<Void>	RescalingStreamTaskNetworkInput.prepareSnapshot(ChannelStateWriter channelStateWriter, long checkpointId)

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

Methods in org.apache.flink.streaming.runtime.tasks that return ChannelStateWriter

Modifier and Type	Method and Description
ChannelStateWriter	SubtaskCheckpointCoordinator.getChannelStateWriter()