bulk-cdk-core-load/io.airbyte.cdk.load.dataflow.state.stats.socket/EmittedStatsStoreImpl

EmittedStatsStoreImpl

@Requires(property = "airbyte.destination.core.data-channel.medium", value = "SOCKET")
@Singleton
class EmittedStatsStoreImpl(catalog: DestinationCatalog) : EmittedStatsStore

Stores counts and bytes per stream. For stats emitter.

Constructors

Link copied to clipboard
constructor(catalog: DestinationCatalog)

Types

Link copied to clipboard
object Companion

Functions

Link copied to clipboard
open override fun getStats(): List<AirbyteMessage>
Link copied to clipboard
open override fun increment(s: DestinationStream.Descriptor, count: Long, bytes: Long)