Skip to main content

publish_snapshot_size

mz_storage::source::mysql::snapshot

Function publish_snapshot_size 

Source 
fn publish_snapshot_size(
    counts: &BTreeMap<MySqlTableName, u64>,
    tables: &BTreeMap<MySqlTableName, Vec<SourceOutputInfo>>,
    export_statistics: &BTreeMap<MySqlTableName, Vec<SourceStatistics>>,
)
Expand description

Publish the snapshot size to each table’s statistics gauges, using the counts computed once during PK sampling. Called leader-only so the summed worker-local gauges reflect the upstream total without double-counting.