mz_storage::source::statistics

Function 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,