io.druid.indexing.overlord.autoscaling

Class SimpleWorkerResourceManagementStrategy

java.lang.Object

io.druid.indexing.overlord.autoscaling.AbstractWorkerResourceManagementStrategy

io.druid.indexing.overlord.autoscaling.SimpleWorkerResourceManagementStrategy

All Implemented Interfaces:

ResourceManagementStrategy<WorkerTaskRunner>

public class SimpleWorkerResourceManagementStrategy
extends AbstractWorkerResourceManagementStrategy

Constructor Summary

Constructors

Constructor and Description
SimpleWorkerResourceManagementStrategy(SimpleWorkerResourceManagementConfig config, com.google.common.base.Supplier<WorkerBehaviorConfig> workerConfigRef, ResourceManagementSchedulerConfig resourceManagementSchedulerConfig, ScheduledExecutorFactory factory)
SimpleWorkerResourceManagementStrategy(SimpleWorkerResourceManagementConfig config, com.google.common.base.Supplier<WorkerBehaviorConfig> workerConfigRef, ResourceManagementSchedulerConfig resourceManagementSchedulerConfig, ScheduledExecutorService exec)

Method Summary

Modifier and Type	Method and Description
protected boolean	doProvision(WorkerTaskRunner runner)
ScalingStats	getStats() Get any interesting stats related to scaling
Collection<ImmutableWorkerInfo>	getWorkers(WorkerTaskRunner runner)

Methods inherited from class io.druid.indexing.overlord.autoscaling.AbstractWorkerResourceManagementStrategy

startManagement, stopManagement

Methods inherited from class java.lang.Object

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

Constructor Detail

SimpleWorkerResourceManagementStrategy

@Inject
public SimpleWorkerResourceManagementStrategy(SimpleWorkerResourceManagementConfig config,
                                                      com.google.common.base.Supplier<WorkerBehaviorConfig> workerConfigRef,
                                                      ResourceManagementSchedulerConfig resourceManagementSchedulerConfig,
                                                      ScheduledExecutorFactory factory)

SimpleWorkerResourceManagementStrategy

public SimpleWorkerResourceManagementStrategy(SimpleWorkerResourceManagementConfig config,
                                              com.google.common.base.Supplier<WorkerBehaviorConfig> workerConfigRef,
                                              ResourceManagementSchedulerConfig resourceManagementSchedulerConfig,
                                              ScheduledExecutorService exec)

Method Detail

doProvision

protected boolean doProvision(WorkerTaskRunner runner)

getWorkers

public Collection<ImmutableWorkerInfo> getWorkers(WorkerTaskRunner runner)

getStats

public ScalingStats getStats()

Description copied from interface: ResourceManagementStrategy

Get any interesting stats related to scaling

Returns:

The ScalingStats or `null` if nothing of interest