bulk-cdk-core-load/io.airbyte.cdk.load.message/CheckpointMessage

CheckpointMessage

sealed interface CheckpointMessage : DestinationMessage

State.

Inheritors

StreamCheckpoint

GlobalCheckpoint

GlobalSnapshotCheckpoint

Types

Checkpoint

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

Companion

object Companion

Stats

data class Stats(val recordCount: Long, val rejectedRecordCount: Long = 0, val additionalStats: Map<String, Double> = emptyMap())

Properties

additionalProperties

abstract val additionalProperties: Map<String, Any>

additionalStats

abstract val additionalStats: MutableMap<String, Double>

checkpointIdRaw

open val checkpointIdRaw: String?

checkpointKey

abstract val checkpointKey: CheckpointKey?

checkpointOrdinalRaw

open val checkpointOrdinalRaw: Int?

checkpointPartitionIds

open val checkpointPartitionIds: List<String>

checkpoints

abstract val checkpoints: List<CheckpointMessage.Checkpoint>

destinationStats

abstract val destinationStats: CheckpointMessage.Stats?

serializedSizeBytes

abstract val serializedSizeBytes: Long

sourceStats

abstract val sourceStats: CheckpointMessage.Stats?

totalBytes

abstract val totalBytes: Long?

totalRecords

abstract val totalRecords: Long?

totalRejectedRecords

abstract val totalRejectedRecords: Long?

Functions

asProtocolMessage

abstract fun asProtocolMessage(): AirbyteMessage

decorateStateMessage

open fun decorateStateMessage(message: AirbyteStateMessage)

updateStats

abstract fun updateStats(destinationStats: CheckpointMessage.Stats? = null, totalRecords: Long? = null, totalBytes: Long? = null, totalRejectedRecords: Long? = null, additionalStats: Map<String, Double> = emptyMap())

withDestinationStats

abstract fun withDestinationStats(stats: CheckpointMessage.Stats): CheckpointMessage