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