bulk-cdk-core-load/io.airbyte.cdk.load.task.internal/HeartbeatTask

HeartbeatTask

class HeartbeatTask(config: DestinationConfiguration, outputQueue: PartitionedQueue<PipelineInputEvent>, checkpointManager: CheckpointManager) : Task

Constructors

Link copied to clipboard
constructor(config: DestinationConfiguration, outputQueue: PartitionedQueue<PipelineInputEvent>, checkpointManager: CheckpointManager)

Properties

Link copied to clipboard

Functions

Link copied to clipboard
open suspend override fun execute()