CommittedStatsStore
Stores stat histograms per stream. For hydrating state messages with stats.
Functions
Link copied to clipboard
fun acceptStats(s: DestinationStream.Descriptor, counts: PartitionHistogram, bytes: PartitionHistogram)
Link copied to clipboard