object TimestampOffset

Source
Offset.scala
Linear Supertypes
AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. TimestampOffset
  2. AnyRef
  3. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Value Members

  1. val Zero: TimestampOffset
  2. def apply(timestamp: Instant, readTimestamp: Instant, seen: Map[String, Long]): TimestampOffset
  3. def apply(timestamp: Instant, seen: Map[String, Long]): TimestampOffset
  4. def toTimestampOffset(offset: Offset): TimestampOffset

    Try to convert the Offset to a TimestampOffset.

    Try to convert the Offset to a TimestampOffset. Epoch timestamp is used for NoOffset.

  5. def unapply(timestampOffset: TimestampOffset): [(, Instant, Map[String, Long])]