GlobalSnapshotCheckpoint

data class GlobalSnapshotCheckpoint(val state: JsonNode?, val sourceStats: CheckpointMessage.Stats?, var destinationStats: CheckpointMessage.Stats? = null, val checkpoints: List<CheckpointMessage.Checkpoint> = emptyList(), val additionalProperties: Map<String, Any>, val originalTypeField: AirbyteStateMessage.AirbyteStateType? = AirbyteStateMessage.AirbyteStateType.GLOBAL, val serializedSizeBytes: Long, val checkpointKey: CheckpointKey? = null, var totalRecords: Long? = null, var totalBytes: Long? = null, var totalRejectedRecords: Long? = null, var additionalStats: MutableMap<String, Double> = mutableMapOf(), val streamCheckpoints: Map<DestinationStream.Descriptor, CheckpointKey>) : CheckpointMessage

Constructors

constructor(state: JsonNode?, sourceStats: CheckpointMessage.Stats?, destinationStats: CheckpointMessage.Stats? = null, checkpoints: List<CheckpointMessage.Checkpoint> = emptyList(), additionalProperties: Map<String, Any>, originalTypeField: AirbyteStateMessage.AirbyteStateType? = AirbyteStateMessage.AirbyteStateType.GLOBAL, serializedSizeBytes: Long, checkpointKey: CheckpointKey? = null, totalRecords: Long? = null, totalBytes: Long? = null, totalRejectedRecords: Long? = null, additionalStats: MutableMap<String, Double> = mutableMapOf(), streamCheckpoints: Map<DestinationStream.Descriptor, CheckpointKey>)

open override val checkpointKey: CheckpointKey? = null

val originalTypeField: AirbyteStateMessage.AirbyteStateType?

val state: JsonNode?

open override var totalBytes: Long?

open override var totalRecords: Long?

open override fun asProtocolMessage(): AirbyteMessage

open fun decorateStateMessage(message: AirbyteStateMessage)

open override fun updateStats(destinationStats: CheckpointMessage.Stats?, totalRecords: Long?, totalBytes: Long?, totalRejectedRecords: Long?, additionalStats: Map<String, Double>)