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>