Enums§
Functions§
- assign_
cdc_ 🔒table_ snapshot_ splits - compose_
job_ splits - is_
parallelized_ 🔒backfill_ enabled - is_
parallelized_ 🔒backfill_ enabled_ cdc_ scan_ fragment - Returns some cdc scan node if the fragment is CDC scan and has parallelized backfill enabled.
- parallel_
cdc_ 🔒table_ backfill_ fragment - reload_
cdc_ table_ snapshot_ splits - single_
merged_ split - 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.