CheckpointOnlyPartitionReader

Constructors

Link copied to clipboard
constructor()

Functions

Link copied to clipboard
open override fun checkpoint(): PartitionReadCheckpoint
Link copied to clipboard
open override fun releaseResources()
Link copied to clipboard
open suspend override fun run()