Function mz_storage::decode::render_decode_cdcv2

pub fn render_decode_cdcv2<G: Scope<Timestamp = Timestamp>, FromTime: Timestamp>(
    input: &Collection<G, DecodeResult<FromTime>, Diff>,
) -> (Collection<G, Row, Diff>, PressOnDropButton)

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.