pub(crate) fn render<G: Scope<Timestamp = MzOffset>>(
scope: G,
config: RawSourceCreationConfig,
connection: PostgresSourceConnection,
table_info: BTreeMap<u32, BTreeMap<usize, SourceOutputInfo>>,
metrics: PgSnapshotMetrics,
) -> (StackedCollection<G, (usize, Result<SourceMessage, DataflowError>)>, StreamVec<G, RewindRequest>, StreamVec<G, Infallible>, StreamVec<G, ReplicationError>, PressOnDropButton)Expand description
Renders the snapshot dataflow. See the module documentation for more information.