bulk-cdk-core-load/io.airbyte.cdk.load.message/PipelineHeartbeat

PipelineHeartbeat

class PipelineHeartbeat<K : WithStream, T> : PipelineEvent<K, T>

Timed recurring event to keep the pipeline alive if no data is coming.

Constructors

Link copied to clipboard
constructor()