checkpoint

open override fun checkpoint(): PartitionReadCheckpoint