risingwave_connector::source::util

Function fill_adaptive_split

source 
pub fn fill_adaptive_split(
    split_template: &SplitImpl,
    actor_in_use: &HashSet<u32>,
) -> ConnectorResult<BTreeMap<Arc<str>, SplitImpl>>