CheckpointValue
data class CheckpointValue(val records: Long, val serializedBytes: Long, val rejectedRecords: Long = 0)
For tracking counts against checkpoints of records read and persisted. Currently it only tracks row count, but could be extended to track bytes moved if needed.