risingwave_frontend::stream_fragmenter::parallelism

Function derive_parallelism

Source 
pub(crate) fn derive_parallelism(
    specific_type_parallelism: Option<ConfigParallelism>,
    global_streaming_parallelism: ConfigParallelism,
) -> Option<Parallelism>