package model
- Alphabetic
- Public
- Protected
Type Members
- sealed trait StreamInterval extends AnyRef
Represents an interval in a single stream partition.
Represents an interval in a single stream partition. Can be either an offset interval, a watermark difference or some combination of both.
- case class StreamPosition(offset: Long, watermark: Timestamp) extends Ordered[StreamPosition] with Product with Serializable
Represents a position in a single partition of a stream.
Represents a position in a single partition of a stream.
- offset
The numeric offset with the partition, i.e. the Kafka offset.
- watermark
The watermark, i.e. maximum timestamp seen up to that point.
- case class StreamRange(topic: String, partition: Int, start: StreamPosition, end: StreamPosition) extends Product with Serializable
Specification of a range of records consumed from a single topic partition, the start and end positions are both inclusive.
- class StreamRangeBuilder extends AnyRef
A mutable builder of StreamRange.
- case class StreamRecord(consumerRecord: ConsumerRecord[Array[Byte], Array[Byte]], watermark: Timestamp) extends Product with Serializable
A single record consumed from the source.
A single record consumed from the source.
- consumerRecord
The Kafka consumer record.
- watermark
The calculated watermark, i.e. the maximum timestamp seen.
- final case class Timestamp(millis: Long) extends AnyVal with Ordered[Timestamp] with Product with Serializable
A value wrapper for unix epoch milliseconds.
Value Members
- object StreamInterval