Package | Description |
---|---|
io.druid.indexing.overlord.setup |
Modifier and Type | Method and Description |
---|---|
AffinityConfig |
FillCapacityWorkerSelectStrategy.getAffinityConfig() |
AffinityConfig |
EqualDistributionWorkerSelectStrategy.getAffinityConfig() |
Modifier and Type | Method and Description |
---|---|
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. |
Constructor and Description |
---|
EqualDistributionWithAffinityWorkerSelectStrategy(AffinityConfig affinityConfig) |
EqualDistributionWorkerSelectStrategy(AffinityConfig affinityConfig) |
FillCapacityWithAffinityWorkerSelectStrategy(AffinityConfig affinityConfig) |
FillCapacityWorkerSelectStrategy(AffinityConfig affinityConfig) |
Copyright © 2011–2018. All rights reserved.