risingwave_stream::executor::backfill::cdc

Module cdc_backill_v2

Source

Structs§

ParallelizedCdcBackfillExecutor

Constants§

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

Functions§

assert_consecutive_splits 🔒
extends_current_actor_bound 🔒
filter_stream_chunk 🔒
is_leftmost_bound 🔒
is_reset_barrier 🔒
is_rightmost_bound 🔒