io.druid.indexing.overlord.setup

Class WorkerSelectUtils

java.lang.Object

io.druid.indexing.overlord.setup.WorkerSelectUtils

public class WorkerSelectUtils
extends Object

Method Summary

Modifier and Type	Method and Description
static ImmutableWorkerInfo	selectWorker(Task task, Map<String,ImmutableWorkerInfo> allWorkers, WorkerTaskRunnerConfig workerTaskRunnerConfig, AffinityConfig affinityConfig, Function<com.google.common.collect.ImmutableMap<String,ImmutableWorkerInfo>,ImmutableWorkerInfo> workerSelector) Helper for WorkerSelectStrategy implementations.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

selectWorker

@Nullable
public static ImmutableWorkerInfo selectWorker(Task task,
                                                         Map<String,ImmutableWorkerInfo> allWorkers,
                                                         WorkerTaskRunnerConfig workerTaskRunnerConfig,
                                                         @Nullable
                                                         AffinityConfig affinityConfig,
                                                         Function<com.google.common.collect.ImmutableMap<String,ImmutableWorkerInfo>,ImmutableWorkerInfo> workerSelector)

Helper for WorkerSelectStrategy implementations.

Parameters:

allWorkers - map of all workers, in the style provided to WorkerSelectStrategy

affinityConfig - affinity config, or null

workerSelector - function that receives a list of eligible workers: version is high enough, worker can run the task, and worker satisfies the affinity config. may return null.

Returns:

selected worker from "allWorkers", or null.