DefaultJdbcStreamStateValue

data class DefaultJdbcStreamStateValue(val primaryKey: Map<String, JsonNode> = mapOf(), val cursors: Map<String, JsonNode> = mapOf())

DefaultJdbcStreamStateValue is used by DefaultJdbcPartitionFactory for deserializing an OpaqueStateValue into a DefaultJdbcPartition. The latter is able to, in turn, serialize a partition boundary into an OpaqueStateValue with DefaultJdbcStreamStateValue.

Constructors

Link copied to clipboard
constructor(primaryKey: Map<String, JsonNode> = mapOf(), cursors: Map<String, JsonNode> = mapOf())

Types

Link copied to clipboard
object Companion

Properties

Link copied to clipboard
val cursors: Map<String, JsonNode>
Link copied to clipboard
val primaryKey: Map<String, JsonNode>