pub(crate) fn render<G: Scope<Timestamp = GtidPartition>>(
scope: G,
config: RawSourceCreationConfig,
connection: MySqlSourceConnection,
source_outputs: Vec<SourceOutputInfo>,
metrics: MySqlSnapshotMetrics,
) -> (StackedCollection<G, (usize, Result<SourceMessage, DataflowError>)>, Stream<G, RewindRequest>, Stream<G, ProgressStatisticsUpdate>, Stream<G, ReplicationError>, PressOnDropButton)
Expand description
Renders the snapshot dataflow. See the module documentation for more information.