Skip to main content

worker_placement_changed

risingwave_meta::stream::scale

Function worker_placement_changed 

Source 
fn worker_placement_changed(
    recovered_workers: &HashMap<WorkerId, WorkerNode>,
    current_workers: &HashMap<WorkerId, WorkerNode>,
) -> bool