EmittedStatsStore

tallies "emitted" record and byte counts from records on read

Inheritors

Functions

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