bulk-cdk-core-load/io.airbyte.cdk.load.state

Package-level declarations

Types

Link copied to clipboard
@JvmInline
value class CheckpointId(val value: String)

Unique identifier for a checkpoint.

Link copied to clipboard
@JvmInline
value class CheckpointIndex(val value: Int)

Represents the ordering of a checkpoint.

Link copied to clipboard
data class CheckpointKey(val checkpointIndex: CheckpointIndex, val checkpointId: CheckpointId) : Comparable<CheckpointKey>

Composite key combining checkpoint index and id. Ordered by index only.

Link copied to clipboard
data class CheckpointValue(val records: Long, val serializedBytes: Long, val rejectedRecords: Long = 0)

Tracks record and byte counts for a checkpoint.