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
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>	ResourceManagementUtil.createLazyWorkerPredicate(SimpleWorkerResourceManagementConfig config)
static com.google.common.base.Predicate<ImmutableWorkerInfo>	ResourceManagementUtil.createValidWorkerPredicate(SimpleWorkerResourceManagementConfig config)
Collection<ImmutableWorkerInfo>	SimpleWorkerResourceManagementStrategy.getWorkers(WorkerTaskRunner runner)

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

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

Modifier and Type	Method and Description
com.google.common.base.Optional<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.
com.google.common.base.Optional<ImmutableWorkerInfo>	JavaScriptWorkerSelectStrategy.findWorkerForTask(WorkerTaskRunnerConfig config, com.google.common.collect.ImmutableMap<String,ImmutableWorkerInfo> zkWorkers, Task task)
com.google.common.base.Optional<ImmutableWorkerInfo>	FillCapacityWorkerSelectStrategy.findWorkerForTask(WorkerTaskRunnerConfig config, com.google.common.collect.ImmutableMap<String,ImmutableWorkerInfo> zkWorkers, Task task)
com.google.common.base.Optional<ImmutableWorkerInfo>	FillCapacityWithAffinityWorkerSelectStrategy.findWorkerForTask(WorkerTaskRunnerConfig config, com.google.common.collect.ImmutableMap<String,ImmutableWorkerInfo> zkWorkers, Task task)
com.google.common.base.Optional<ImmutableWorkerInfo>	EqualDistributionWorkerSelectStrategy.findWorkerForTask(WorkerTaskRunnerConfig config, com.google.common.collect.ImmutableMap<String,ImmutableWorkerInfo> zkWorkers, Task task)

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)
com.google.common.base.Optional<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.
com.google.common.base.Optional<ImmutableWorkerInfo>	JavaScriptWorkerSelectStrategy.findWorkerForTask(WorkerTaskRunnerConfig config, com.google.common.collect.ImmutableMap<String,ImmutableWorkerInfo> zkWorkers, Task task)
com.google.common.base.Optional<ImmutableWorkerInfo>	FillCapacityWorkerSelectStrategy.findWorkerForTask(WorkerTaskRunnerConfig config, com.google.common.collect.ImmutableMap<String,ImmutableWorkerInfo> zkWorkers, Task task)
com.google.common.base.Optional<ImmutableWorkerInfo>	FillCapacityWithAffinityWorkerSelectStrategy.findWorkerForTask(WorkerTaskRunnerConfig config, com.google.common.collect.ImmutableMap<String,ImmutableWorkerInfo> zkWorkers, Task task)
com.google.common.base.Optional<ImmutableWorkerInfo>	EqualDistributionWorkerSelectStrategy.findWorkerForTask(WorkerTaskRunnerConfig config, com.google.common.collect.ImmutableMap<String,ImmutableWorkerInfo> zkWorkers, Task task)