Interface CommittableMessage<CommT>

    • Field Detail

      • EOI

        @Deprecated
        static final long EOI
        Deprecated.
        the special value is not used anymore at all (remove with Flink 2.2)
        Special value for checkpointId for the end of input in case of batch commit or final checkpoint.
        See Also:
        Constant Field Values
    • Method Detail

      • getSubtaskId

        int getSubtaskId()
        The subtask that created this committable.
      • getCheckpointId

        @Deprecated
        default OptionalLong getCheckpointId()
        Deprecated.
        Returns the checkpoint id or empty if the message does not belong to a checkpoint. In that case, the committable was created at the end of input (e.g., in batch mode).
        See Also:
        getCheckpointIdOrEOI()
      • getCheckpointIdOrEOI

        long getCheckpointIdOrEOI()
        Deprecated.
        the special value EOI is not used anymore
        Returns the checkpoint id or EOI if this message belong to the final checkpoint or the batch commit.