Function dataflow::source::create_source_simple

pub fn create_source_simple<G, C>(
    config: SourceConfig<'_, G>, 
    connector: C
) -> ((Stream<G, (Row, Timestamp, Diff)>, Stream<G, SourceError>), Option<SourceToken>) where
    G: Scope<Timestamp = Timestamp>,
    C: SimpleSource + Send + 'static, 

Creates a source dataflow operator from a connector implementing SimpleSource