risingwave_frontend::scheduler::fast_insert

Function choose_worker

source 
fn choose_worker(
    table_id: &TableId,
    frontend_env: &FrontendEnv,
    request_id: u32,
) -> Result<WorkerNode, SchedulerError>