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

CheckpointValue

data class CheckpointValue(val records: Long, val serializedBytes: Long, val rejectedRecords: Long = 0)

Tracks record and byte counts for a checkpoint.

Constructors

Link copied to clipboard
constructor(records: Long, serializedBytes: Long, rejectedRecords: Long = 0)

Properties

Link copied to clipboard
val records: Long
Link copied to clipboard
Link copied to clipboard

Functions

Link copied to clipboard
open operator override fun equals(other: Any?): Boolean
Link copied to clipboard
operator fun plus(other: CheckpointValue): CheckpointValue