Package org.apache.flink.runtime.io.network.api

Class Summary

Class	Description
CancelCheckpointMarker	The CancelCheckpointMarker travels through the data streams, similar to the CheckpointBarrier, but signals that a certain checkpoint should be canceled.
CheckpointBarrier	Checkpoint barriers are used to align checkpoints throughout the streaming topology.
EndOfData	This event indicates there will be no more data records in a subpartition.
EndOfPartitionEvent	This event marks a subpartition as fully consumed.
EndOfSegmentEvent	EndOfSegmentEvent is used to notify the downstream switch tiers in tiered storage shuffle mode.
EndOfSuperstepEvent	Marks the end of a superstep of one particular iteration superstep.
EventAnnouncement	EventAnnouncement is announcing presence or receiving of an AbstractEvent.
SubtaskConnectionDescriptor	An event that is used to (de)multiplex old channels over the same new channel.
TaskEventHandler	The event handler manages EventListener instances and allows to publish events to them.

Enum Summary

Enum	Description
StopMode	Tells if the job is stopping because of consuming all data.