fill_adaptive_split

risingwave_connector::source

Function fill_adaptive_split 

Source 
pub fn fill_adaptive_split(
    split_template: &SplitImpl,
    actor_count: usize,
) -> ConnectorResult<BTreeMap<Arc<str>, SplitImpl>>