Function mz_storage::render::debezium::render
source · pub(crate) fn render<G, FromTime: Timestamp>(
envelope: &DebeziumEnvelope,
input: &Collection<G, DecodeResult<FromTime>, Diff>
) -> (Collection<G, Row, Diff>, Collection<G, DataflowError, Diff>)where
G: ScopeParent<Timestamp = Timestamp> + Scope,