The CancelCheckpointMarker travels through the data streams, similar to the
Checkpoint barriers are used to align checkpoints throughout the streaming topology.
This event indicates there will be no more data records in a subpartition.
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
Tells if the job is stopping because of consuming all data.
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.