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