Function mz_storage::source::generator::key_value::render_statistics_operator

source ยท
pub fn render_statistics_operator<G: Scope<Timestamp = MzOffset>>(
    scope: &G,
    config: RawSourceCreationConfig,
    committed_uppers: impl Stream<Item = Antichain<MzOffset>> + 'static,
) -> (Stream<G, ProgressStatisticsUpdate>, PressOnDropButton)