Type Members

1.  trait Checkpointable extends AnyRef

   Representation of an Event Hubs checkpoint.

   Representation of an Event Hubs checkpoint. Not intended for user extension

   Annotations

   @DoNotInherit()

2.  final case class LocationInPartition(offset: Long, sequenceNr: Long) extends PartiallyOrdered[LocationInPartition] with Product with Serializable

   An event in a given partition can be identified by a sequence number, which is guaranteed to be incremented by 1 from one event to the next in a partition, and an offset, which in the current implementation is (per https://stackoverflow.com/a/66294545/5641244 from a Microsoft engineer) "the number of bytes from the beginning of the partition to the first byte of the event".

   An event in a given partition can be identified by a sequence number, which is guaranteed to be incremented by 1 from one event to the next in a partition, and an offset, which in the current implementation is (per https://stackoverflow.com/a/66294545/5641244 from a Microsoft engineer) "the number of bytes from the beginning of the partition to the first byte of the event".

   This does imply that for instances of this class which came from the same partition, their offsets and sequence numbers will compare the same (viz. (this.offset < that.offset) == (this.sequenceNr < that.sequenceNr)). However, for instances which came from different partitions, this relationship may not hold (consider one partition where most events are a few bytes while another partition where most events are larger than a hundred thousand bytes: an event with sequence number 5 in the former partition might have offset 96, while an event with sequence number 2 from the latter partition could have offset 205000).

   The compareTo method does not fully obey the contract of java.lang.Comparable.compareTo.