io.druid.indexing.overlord.autoscaling

Class PendingTaskBasedWorkerResourceManagementStrategy

java.lang.Object

io.druid.indexing.overlord.autoscaling.AbstractWorkerResourceManagementStrategy

io.druid.indexing.overlord.autoscaling.PendingTaskBasedWorkerResourceManagementStrategy

All Implemented Interfaces:

ResourceManagementStrategy<WorkerTaskRunner>

public class PendingTaskBasedWorkerResourceManagementStrategy
extends AbstractWorkerResourceManagementStrategy

Constructor Summary

Constructors

Constructor and Description
PendingTaskBasedWorkerResourceManagementStrategy(PendingTaskBasedWorkerResourceManagementConfig config, com.google.common.base.Supplier<WorkerBehaviorConfig> workerConfigRef, ResourceManagementSchedulerConfig resourceManagementSchedulerConfig, com.metamx.common.concurrent.ScheduledExecutorFactory factory)
PendingTaskBasedWorkerResourceManagementStrategy(PendingTaskBasedWorkerResourceManagementConfig config, com.google.common.base.Supplier<WorkerBehaviorConfig> workerConfigRef, ResourceManagementSchedulerConfig resourceManagementSchedulerConfig, ScheduledExecutorService exec)

Method Summary

Modifier and Type	Method and Description
boolean	doProvision(WorkerTaskRunner runner)
boolean	doTerminate(WorkerTaskRunner runner)
ScalingStats	getStats() Get any interesting stats related to scaling

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

PendingTaskBasedWorkerResourceManagementStrategy

@Inject
public PendingTaskBasedWorkerResourceManagementStrategy(PendingTaskBasedWorkerResourceManagementConfig config,
                                                                com.google.common.base.Supplier<WorkerBehaviorConfig> workerConfigRef,
                                                                ResourceManagementSchedulerConfig resourceManagementSchedulerConfig,
                                                                com.metamx.common.concurrent.ScheduledExecutorFactory factory)

PendingTaskBasedWorkerResourceManagementStrategy

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

Method Detail

doProvision

public boolean doProvision(WorkerTaskRunner runner)

doTerminate

public boolean doTerminate(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