Uses of Class
io.druid.indexing.overlord.ImmutableWorkerInfo

Packages that use ImmutableWorkerInfo

Package	Description
io.druid.indexing.overlord
io.druid.indexing.overlord.autoscaling
io.druid.indexing.overlord.setup

Uses of ImmutableWorkerInfo in io.druid.indexing.overlord

Methods in io.druid.indexing.overlord that return ImmutableWorkerInfo

Modifier and Type	Method and Description
ImmutableWorkerInfo	ZkWorker.toImmutable()

Methods in io.druid.indexing.overlord that return types with arguments of type ImmutableWorkerInfo

Modifier and Type	Method and Description
Collection<ImmutableWorkerInfo>	RemoteTaskRunner.getBlackListedWorkers()
Collection<ImmutableWorkerInfo>	WorkerTaskRunner.getWorkers() List of known workers who can accept tasks for running
Collection<ImmutableWorkerInfo>	RemoteTaskRunner.getWorkers()

Method parameters in io.druid.indexing.overlord with type arguments of type ImmutableWorkerInfo

Modifier and Type	Method and Description
Collection<Worker>	WorkerTaskRunner.markWorkersLazy(com.google.common.base.Predicate<ImmutableWorkerInfo> isLazyWorker, int maxWorkers) Check which workers can be marked as lazy
Collection<Worker>	RemoteTaskRunner.markWorkersLazy(com.google.common.base.Predicate<ImmutableWorkerInfo> isLazyWorker, int maxWorkers)

Uses of ImmutableWorkerInfo in io.druid.indexing.overlord.autoscaling

Methods in io.druid.indexing.overlord.autoscaling that return types with arguments of type ImmutableWorkerInfo

Modifier and Type	Method and Description
static com.google.common.base.Predicate<ImmutableWorkerInfo>	ProvisioningUtil.createLazyWorkerPredicate(SimpleWorkerProvisioningConfig config)
static com.google.common.base.Predicate<ImmutableWorkerInfo>	ProvisioningUtil.createValidWorkerPredicate(SimpleWorkerProvisioningConfig config)

Uses of ImmutableWorkerInfo in io.druid.indexing.overlord.setup

Methods in io.druid.indexing.overlord.setup that return ImmutableWorkerInfo

Modifier and Type	Method and Description
ImmutableWorkerInfo	WorkerSelectStrategy.findWorkerForTask(WorkerTaskRunnerConfig config, com.google.common.collect.ImmutableMap<String,ImmutableWorkerInfo> zkWorkers, Task task) Customizable logic for selecting a worker to run a task.
ImmutableWorkerInfo	JavaScriptWorkerSelectStrategy.findWorkerForTask(WorkerTaskRunnerConfig config, com.google.common.collect.ImmutableMap<String,ImmutableWorkerInfo> zkWorkers, Task task)
ImmutableWorkerInfo	FillCapacityWorkerSelectStrategy.findWorkerForTask(WorkerTaskRunnerConfig config, com.google.common.collect.ImmutableMap<String,ImmutableWorkerInfo> zkWorkers, Task task)
ImmutableWorkerInfo	EqualDistributionWorkerSelectStrategy.findWorkerForTask(WorkerTaskRunnerConfig config, com.google.common.collect.ImmutableMap<String,ImmutableWorkerInfo> zkWorkers, Task task)
static ImmutableWorkerInfo	WorkerSelectUtils.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.

Method parameters in io.druid.indexing.overlord.setup with type arguments of type ImmutableWorkerInfo

Modifier and Type	Method and Description
String	JavaScriptWorkerSelectStrategy.SelectorFunction.apply(WorkerTaskRunnerConfig config, com.google.common.collect.ImmutableMap<String,ImmutableWorkerInfo> zkWorkers, Task task)
ImmutableWorkerInfo	WorkerSelectStrategy.findWorkerForTask(WorkerTaskRunnerConfig config, com.google.common.collect.ImmutableMap<String,ImmutableWorkerInfo> zkWorkers, Task task) Customizable logic for selecting a worker to run a task.
ImmutableWorkerInfo	JavaScriptWorkerSelectStrategy.findWorkerForTask(WorkerTaskRunnerConfig config, com.google.common.collect.ImmutableMap<String,ImmutableWorkerInfo> zkWorkers, Task task)
ImmutableWorkerInfo	FillCapacityWorkerSelectStrategy.findWorkerForTask(WorkerTaskRunnerConfig config, com.google.common.collect.ImmutableMap<String,ImmutableWorkerInfo> zkWorkers, Task task)
ImmutableWorkerInfo	EqualDistributionWorkerSelectStrategy.findWorkerForTask(WorkerTaskRunnerConfig config, com.google.common.collect.ImmutableMap<String,ImmutableWorkerInfo> zkWorkers, Task task)
static ImmutableWorkerInfo	WorkerSelectUtils.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.
static ImmutableWorkerInfo	WorkerSelectUtils.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.
static ImmutableWorkerInfo	WorkerSelectUtils.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.