risingwave_frontend::handler::explain_analyze_stream_job::net

Function get_executor_stats

Source 
pub(super) async fn get_executor_stats(
    handler_args: &HandlerArgs,
    worker_nodes: &[WorkerNode],
    executor_ids: &HashSet<u64>,
    dispatcher_fragment_ids: &[u32],
    profiling_duration: Duration,
) -> Result<ExecutorStats, RwError>