pub fn render_decode_cdcv2<G: Scope<Timestamp = Timestamp>, FromTime: Timestamp>(
input: &Collection<G, DecodeResult<FromTime>, Diff>,
) -> (Collection<G, Row, Diff>, PressOnDropButton)
Expand description
Decode delimited CDCv2 messages.
This not only literally decodes the avro-encoded messages, but also builds a differential dataflow collection that respects the data and progress messages in the underlying CDCv2 stream.