Function dataflow::source::create_source_simple [−][src]
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,
Expand description
Creates a source dataflow operator from a connector implementing SimpleSource