final case class KafkaCheckpoint(id: String, currentOffsets: Map[(String, Int), Long]) extends Checkpoint with Product with Serializable
Linear Supertypes
Ordering
- Alphabetic
- By Inheritance
Inherited
- KafkaCheckpoint
- Serializable
- Serializable
- Product
- Equals
- Checkpoint
- AnyRef
- Any
- Hide All
- Show All
Visibility
- Public
- All
Instance Constructors
- new KafkaCheckpoint(id: String, currentOffsets: Map[(String, Int), Long])
Value Members
- val currentOffsets: Map[(String, Int), Long]
-
val
id: String
- Definition Classes
- KafkaCheckpoint → Checkpoint
-
def
merge(other: Checkpoint): Checkpoint
- Definition Classes
- KafkaCheckpoint → Checkpoint
-
def
update(row: Row, colIdxMap: Map[String, Int])(implicit streamConf: StreamConfig): Checkpoint
- Definition Classes
- KafkaCheckpoint → Checkpoint