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

FreeingAnnotatingCheckpointConsumer

@Singleton
class FreeingAnnotatingCheckpointConsumer(consumer: OutputConsumer) : SuspendFunction4<Reserved<CheckpointMessage>, Long, Long, Long, Unit>

Constructors

Link copied to clipboard
constructor(consumer: OutputConsumer)

Functions

Link copied to clipboard
open suspend operator override fun invoke(message: Reserved<CheckpointMessage>, totalRecords: Long, totalBytes: Long, totalRejectedRecords: Long)