Function dataflow::render::debezium::render [−][src]
pub(crate) fn render<G: Scope>(
envelope: &DebeziumEnvelope,
input: &Stream<G, DecodeResult>,
debug_name: String,
metrics: Metrics,
src_id: GlobalId,
dataflow_id: usize
) -> Collection<G, Result<Row, DataflowError>, Diff>