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

StatsEmitter

@Singleton
@Requires(property = "airbyte.destination.core.data-channel.medium", value = "SOCKET")
class StatsEmitter(syncManager: SyncManager, catalog: DestinationCatalog, outputConsumer: DummyStatsMessageConsumer, @Nullable @Named(value = "statsEmissionFrequencyOverride") emissionFrequencyMillis: Long? = null) : Task

Constructors

Link copied to clipboard
constructor(syncManager: SyncManager, catalog: DestinationCatalog, outputConsumer: DummyStatsMessageConsumer, @Nullable @Named(value = "statsEmissionFrequencyOverride") emissionFrequencyMillis: Long? = null)

Types

Link copied to clipboard
object Companion

Properties

Link copied to clipboard

Functions

Link copied to clipboard
open suspend override fun execute()