compose_job_splits

risingwave_meta::stream::cdc

Function compose_job_splits 

Source 
pub fn compose_job_splits(
    job_id: JobId,
    splits: Vec<(i64, Vec<u8>, Vec<u8>, i16)>,
) -> MetaResult<CdcTableSnapshotSplits>