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

CommittedStatsStore

@Singleton

class CommittedStatsStore(source)

Stores stat histograms per stream. For hydrating state messages with stats.

Constructors

CommittedStatsStore

constructor()

Functions

fun acceptStats(s: DestinationStream.Descriptor, counts: PartitionHistogram, bytes: PartitionHistogram)

fun commitStats(s: DestinationStream.Descriptor, key: StateKey): CommitStatsResult