io.druid.indexing.overlord.scaling

Class ResourceManagementScheduler

java.lang.Object

io.druid.indexing.overlord.scaling.ResourceManagementScheduler

Direct Known Subclasses:

NoopResourceManagementScheduler

public class ResourceManagementScheduler
extends Object

The ResourceManagementScheduler schedules a check for when worker nodes should potentially be created or destroyed. It uses a TaskRunner to return all pending tasks in the system and the status of the worker nodes in the system. The ResourceManagementScheduler does not contain the logic to decide whether provision or termination should actually occur. That decision is made in the ResourceManagementStrategy.

Constructor Summary

Constructors

Constructor and Description
ResourceManagementScheduler(RemoteTaskRunner taskRunner, ResourceManagementStrategy resourceManagementStrategy, ResourceManagementSchedulerConfig config, ScheduledExecutorService exec)

Method Summary

Methods

Modifier and Type	Method and Description
ScalingStats	getStats()
void	start()
void	stop()

Methods inherited from class java.lang.Object

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

Constructor Detail

ResourceManagementScheduler

public ResourceManagementScheduler(RemoteTaskRunner taskRunner,
                           ResourceManagementStrategy resourceManagementStrategy,
                           ResourceManagementSchedulerConfig config,
                           ScheduledExecutorService exec)

Method Detail

start

public void start()

stop

public void stop()

getStats

public ScalingStats getStats()