risingwave_meta::stream::source_manager

Function build_actor_split_impls

source 
pub fn build_actor_split_impls(
    actor_splits: &HashMap<u32, ConnectorSplits>,
) -> HashMap<ActorId, Vec<SplitImpl>>