Skip to main content

Module cdc_backill_v2

Module cdc_backill_v2 

Source

Structsยง

ParallelizedCdcBackfillExecutor

Enumsยง

SnapshotAttemptState ๐Ÿ”’

Functionsยง

assert_consecutive_splits ๐Ÿ”’
extend_backfill_progress ๐Ÿ”’
extends_current_actor_bound ๐Ÿ”’
filter_stream_chunk ๐Ÿ”’
Keep rows whose snapshot split-column value falls within boundโ€™s half-open range [left, right), preserving their operations and relative order through a visibility bitmap. Returns None when no bounds are supplied or no visible rows fall within the range.
is_leftmost_bound ๐Ÿ”’
is_reset_barrier ๐Ÿ”’
is_rightmost_bound ๐Ÿ”’
route_cdc_chunk ๐Ÿ”’
Splits CDC rows into chunks to forward immediately or buffer for replay. Returns None for either result when it contains no rows.