Function try_init_parallel_cdc_table_snapshot_splits

Source
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.