Interface CommittableMessage<CommT>

    • Method Detail

      • getSubtaskId

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

        OptionalLong getCheckpointId()
        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).