io.druid.indexing.overlord.scaling

Class SimpleResourceManagementStrategy

java.lang.Object

io.druid.indexing.overlord.scaling.SimpleResourceManagementStrategy

All Implemented Interfaces:

ResourceManagementStrategy

public class SimpleResourceManagementStrategy
extends Object
implements ResourceManagementStrategy

Constructor Summary

Constructors

Constructor and Description
SimpleResourceManagementStrategy(AutoScalingStrategy autoScalingStrategy, SimpleResourceManagementConfig config, com.google.common.base.Supplier<WorkerSetupData> workerSetupDataRef)

Method Summary

Methods

Modifier and Type	Method and Description
boolean	doProvision(Collection<RemoteTaskRunnerWorkItem> pendingTasks, Collection<ZkWorker> zkWorkers)
boolean	doTerminate(Collection<RemoteTaskRunnerWorkItem> pendingTasks, Collection<ZkWorker> zkWorkers)
ScalingStats	getStats()

Methods inherited from class java.lang.Object

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

Constructor Detail

SimpleResourceManagementStrategy

@Inject
public SimpleResourceManagementStrategy(AutoScalingStrategy autoScalingStrategy,
                                       SimpleResourceManagementConfig config,
                                       com.google.common.base.Supplier<WorkerSetupData> workerSetupDataRef)

Method Detail

doProvision

public boolean doProvision(Collection<RemoteTaskRunnerWorkItem> pendingTasks,
                  Collection<ZkWorker> zkWorkers)

Specified by:

doProvision in interface ResourceManagementStrategy

doTerminate

public boolean doTerminate(Collection<RemoteTaskRunnerWorkItem> pendingTasks,
                  Collection<ZkWorker> zkWorkers)

Specified by:

doTerminate in interface ResourceManagementStrategy

getStats

public ScalingStats getStats()

Specified by:

getStats in interface ResourceManagementStrategy