Package | Description |
---|---|
io.druid.indexing.overlord | |
io.druid.indexing.overlord.autoscaling | |
io.druid.indexing.overlord.setup |
Modifier and Type | Method and Description |
---|---|
ImmutableWorkerInfo |
ZkWorker.toImmutable() |
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() |
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) |
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) |
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. |
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. |
Copyright © 2011–2018. All rights reserved.