Function mz_storage::source::statistics::process_statistics

source ยท 
pub fn process_statistics<G, FromTime>(
    scope: G,
    source_id: GlobalId,
    worker_id: usize,
    stats_stream: Stream<G, ProgressStatisticsUpdate>,
    source_statistics: SourceStatistics,
)
where
    G: Scope<Timestamp = FromTime>,
    FromTime: SourceTimestamp,