StateStatsEnricher
@Singleton
Decorates states with destination stats — both top level and per stream.
Constructors
Link copied to clipboard
constructor(statsStore: CommittedStatsStore, namespaceMapper: NamespaceMapper, stateAdditionalStatsStore: StateAdditionalStatsStore)
Functions
Link copied to clipboard
Link copied to clipboard
Link copied to clipboard
Link copied to clipboard
fun enrichTopLevelDestinationStats(msg: CheckpointMessage, desc: DestinationStream.Descriptor, partitionKeys: List<PartitionKey>, count: Long): CheckpointMessage
Link copied to clipboard
fun enrichTopLevelDestinationStatsGlobalState(msg: CheckpointMessage, count: Long): CheckpointMessage
Link copied to clipboard