derive_parallelism

risingwave_frontend::stream_fragmenter::parallelism

Function derive_parallelism 

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