risingwave_stream::executor::backfill::cdc

Module cdc_backill_v2

Source

Structs§

ParallelizedCdcBackfillExecutor

Functions§

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