pub(crate) async fn try_init_parallel_cdc_table_snapshot_splits(
table_id: u32,
table_desc: &ExternalTableDesc,
meta_store: &SqlMetaStore,
per_table_options: &Option<StreamCdcScanOptions>,
insert_batch_size: u64,
sleep_split_interval: u64,
sleep_duration_millis: u64,
) -> MetaResult<()>
Expand description
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.