Checkpoint

data class Checkpoint(val unmappedNamespace: String?, val unmappedName: String, val state: JsonNode?, val additionalProperties: LinkedHashMap<String, Any> = LinkedHashMap())

Constructors

constructor(unmappedNamespace: String?, unmappedName: String, state: JsonNode?, additionalProperties: LinkedHashMap<String, Any> = LinkedHashMap())

val state: JsonNode?

fun asProtocolObject(): AirbyteStreamState

fun updateStats(committedRecords: Long, bytes: Long, rejectedRecords: Long = 0)