Function mz_storage::decode::render_decode_cdcv2

source ·

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.

Function mz_storage::decode::render_decode_cdcv2Copy item path

Function mz_storage::decode::render_decode_cdcv2