Checkpoint

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

Constructors

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

Properties

Link copied to clipboard
val state: JsonNode?
Link copied to clipboard
Link copied to clipboard

Functions

Link copied to clipboard
fun asProtocolObject(): AirbyteStreamState
Link copied to clipboard
fun updateStats(committedRecords: Long, bytes: Long, rejectedRecords: Long = 0)