case class TokenedEvents(events: Chunk[ByteBuffer], ack: Token, earliestSourceTstamp: Option[Instant]) extends Product with Serializable
The events as they are fed into a EventProcessor
- events
Each item in the Chunk is an event read from the external stream, before parsing
- ack
The EventProcessor must emit this token after it has fully processed the batch of events. When the EventProcessor emits the token, it is an instruction to the SourceAndAck to ack/checkpoint the events.
- earliestSourceTstamp
The timestamp that an event was originally written to the source stream. Used for calculating the latency metric.
- Alphabetic
- By Inheritance
- TokenedEvents
- Serializable
- Product
- Equals
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Instance Constructors
- new TokenedEvents(events: Chunk[ByteBuffer], ack: Token, earliestSourceTstamp: Option[Instant])
- events
Each item in the Chunk is an event read from the external stream, before parsing
- ack
The EventProcessor must emit this token after it has fully processed the batch of events. When the EventProcessor emits the token, it is an instruction to the SourceAndAck to ack/checkpoint the events.
- earliestSourceTstamp
The timestamp that an event was originally written to the source stream. Used for calculating the latency metric.
Value Members
- final def !=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def ##: Int
- Definition Classes
- AnyRef → Any
- final def ==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- val ack: Token
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @HotSpotIntrinsicCandidate() @native()
- val earliestSourceTstamp: Option[Instant]
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- val events: Chunk[ByteBuffer]
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @HotSpotIntrinsicCandidate() @native()
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- final def ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- final def notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @HotSpotIntrinsicCandidate() @native()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @HotSpotIntrinsicCandidate() @native()
- def productElementNames: Iterator[String]
- Definition Classes
- Product
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- final def wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException]) @native()
- final def wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])