risingwave_stream::executor::backfill::cdc

Module cdc_backfill

Source

Structs§

CdcBackfillExecutor

Constants§

METADATA_STATE_LEN 🔒
split_id, is_finished, row_count, cdc_offset all occupy 1 column each.

Functions§

build_reader_and_poll_upstream 🔒
parse_debezium_chunk 🔒
transform_upstream