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

StreamCheckpoint

data class StreamCheckpoint(val checkpoint: CheckpointMessage.Checkpoint, val sourceStats: CheckpointMessage.Stats?, var destinationStats: CheckpointMessage.Stats? = null, val additionalProperties: Map<String, Any> = emptyMap(), 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()) : CheckpointMessage

Constructors

StreamCheckpoint

constructor(unmappedNamespace: String?, unmappedName: String, blob: String, sourceRecordCount: Long, additionalProperties: Map<String, Any> = emptyMap(), destinationRecordCount: Long? = null, checkpointKey: CheckpointKey? = null, totalRecords: Long? = null, totalBytes: Long? = null, additionalStats: MutableMap<String, Double> = mutableMapOf())

Convenience constructor, intended for use in tests.

constructor(checkpoint: CheckpointMessage.Checkpoint, sourceStats: CheckpointMessage.Stats?, destinationStats: CheckpointMessage.Stats? = null, additionalProperties: Map<String, Any> = emptyMap(), serializedSizeBytes: Long, checkpointKey: CheckpointKey? = null, totalRecords: Long? = null, totalBytes: Long? = null, totalRejectedRecords: Long? = null, additionalStats: MutableMap<String, Double> = mutableMapOf())

Properties

additionalProperties

open override val additionalProperties: Map<String, Any>

additionalStats

open override var additionalStats: MutableMap<String, Double>

checkpoint

val checkpoint: CheckpointMessage.Checkpoint

checkpointIdRaw

open val checkpointIdRaw: String?

checkpointKey

open override val checkpointKey: CheckpointKey? = null

checkpointOrdinalRaw

open val checkpointOrdinalRaw: Int?

checkpointPartitionIds

open val checkpointPartitionIds: List<String>

checkpoints

open override val checkpoints: List<CheckpointMessage.Checkpoint>

destinationStats

open override var destinationStats: CheckpointMessage.Stats?

serializedSizeBytes

open override val serializedSizeBytes: Long

sourceStats

open override val sourceStats: CheckpointMessage.Stats?

totalBytes

open override var totalBytes: Long?

totalRecords

open override var totalRecords: Long?

totalRejectedRecords

open override var totalRejectedRecords: Long?

Functions

asProtocolMessage

open override fun asProtocolMessage(): AirbyteMessage

decorateStateMessage

open fun decorateStateMessage(message: AirbyteStateMessage)

updateStats

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

withDestinationStats

open override fun withDestinationStats(stats: CheckpointMessage.Stats): StreamCheckpoint