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
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.