Function mz_storage::source::mysql::statistics::render
source ยท pub(crate) fn render<G: Scope<Timestamp = GtidPartition>>(
scope: G,
config: RawSourceCreationConfig,
connection: MySqlSourceConnection,
resume_uppers: impl Stream<Item = Antichain<GtidPartition>> + 'static,
) -> (Stream<G, ProgressStatisticsUpdate>, Stream<G, ReplicationError>, Stream<G, Probe<GtidPartition>>, PressOnDropButton)
Expand description
Renders the statistics dataflow.