Skip to main content

get_distributed_worker_resolver

datafusion_distributed

Function get_distributed_worker_resolver 

Source 
pub fn get_distributed_worker_resolver(
    cfg: &SessionConfig,
) -> Result<Arc<dyn WorkerResolver>, DataFusionError>
Expand description

Gets the WorkerResolver from the SessionConfig’s extensions. Typically called inside [RouteTasksHandler::route_tasks] to resolve the worker URLs available for distributed tasks.