The CancelCheckpointMarker travels through the data streams, similar to the
Checkpoint barriers are used to align checkpoints throughout the streaming topology.
This event marks a subpartition as fully consumed.
Marks the end of a superstep of one particular iteration superstep.
An event that is used to (de)multiplex old channels over the same new channel.
The event handler manages
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.