Module cdc

Functions

assign_cdc_table_snapshot_splits 🔒

assign_cdc_table_snapshot_splits_for_replace_table 🔒

assign_cdc_table_snapshot_splits_impl 🔒

assign_cdc_table_snapshot_splits_pairs 🔒

is_parallelized_backfill_enabled

is_parallelized_backfill_enabled_cdc_scan_fragment 🔒

Returns true if the fragment is CDC scan and has parallelized backfill enabled.

try_get_cdc_table_snapshot_splits

try_init_parallel_cdc_table_snapshot_splits 🔒

A CDC table snapshot splits can only be successfully initialized once. Subsequent attempts to write to the metastore with the same primary key will be rejected.