Class CancelCheckpointMarker

  • All Implemented Interfaces:
    IOReadableWritable

    public class CancelCheckpointMarker
    extends RuntimeEvent
    The CancelCheckpointMarker travels through the data streams, similar to the CheckpointBarrier, but signals that a certain checkpoint should be canceled. Any in-progress alignment for that checkpoint needs to be canceled and regular processing should be resumed.
    • Constructor Detail

      • CancelCheckpointMarker

        public CancelCheckpointMarker​(long checkpointId)
    • Method Detail

      • getCheckpointId

        public long getCheckpointId()
      • write

        public void write​(DataOutputView out)
                   throws IOException
        Description copied from interface: IOReadableWritable
        Writes the object's internal data to the given data output view.
        Parameters:
        out - the output view to receive the data.
        Throws:
        IOException - thrown if any error occurs while writing to the output stream
      • read

        public void read​(DataInputView in)
                  throws IOException
        Description copied from interface: IOReadableWritable
        Reads the object's internal data from the given data input view.
        Parameters:
        in - the input view to read the data from
        Throws:
        IOException - thrown if any error occurs while reading from the input stream
      • hashCode

        public int hashCode()
        Overrides:
        hashCode in class Object