risingwave_meta::stream::source_manager

Function build_actor_connector_splits

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