bulk-cdk-core-load/io.airbyte.cdk.load.dataflow.state.stats.stdio/NoopEmittedStatsStore

NoopEmittedStatsStore

@Requires(property = "airbyte.destination.core.data-channel.medium", value = "STDIO")
@Singleton
class NoopEmittedStatsStore : EmittedStatsStore

STDIO doesn't need to store emitted stats specially

Constructors

Link copied to clipboard
constructor()

Functions

Link copied to clipboard
open override fun getStats(): Nothing?
Link copied to clipboard
open override fun increment(s: DestinationStream.Descriptor, count: Long, bytes: Long)