Skip to main content

effective_streaming_job_parallelism

risingwave_meta_service::stream_service

Function effective_streaming_job_parallelism 

Source 
fn effective_streaming_job_parallelism(
    job_status: JobStatus,
    parallelism: StreamingParallelism,
    adaptive_parallelism_strategy: Option<String>,
    backfill_parallelism: Option<StreamingParallelism>,
    backfill_adaptive_parallelism_strategy: Option<String>,
) -> (StreamingParallelism, Option<String>)