io.druid.indexing.overlord.autoscaling

Class AbstractWorkerResourceManagementStrategy

java.lang.Object

io.druid.indexing.overlord.autoscaling.AbstractWorkerResourceManagementStrategy

All Implemented Interfaces:

ResourceManagementStrategy<WorkerTaskRunner>

Direct Known Subclasses:

PendingTaskBasedWorkerResourceManagementStrategy, SimpleWorkerResourceManagementStrategy

public abstract class AbstractWorkerResourceManagementStrategy
extends Object
implements ResourceManagementStrategy<WorkerTaskRunner>

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	AbstractWorkerResourceManagementStrategy(ResourceManagementSchedulerConfig resourceManagementSchedulerConfig, ScheduledExecutorService exec)

Method Summary

Modifier and Type	Method and Description
void	startManagement(WorkerTaskRunner runner) Equivalent to start() but requires a specific runner instance which holds state of interest.
void	stopManagement() Equivalent to stop() Should be called from TaskRunner's lifecycle

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.druid.indexing.overlord.autoscaling.ResourceManagementStrategy

getStats

Constructor Detail

AbstractWorkerResourceManagementStrategy

protected AbstractWorkerResourceManagementStrategy(ResourceManagementSchedulerConfig resourceManagementSchedulerConfig,
                                                   ScheduledExecutorService exec)

Method Detail

startManagement

public void startManagement(WorkerTaskRunner runner)

Description copied from interface: ResourceManagementStrategy

Equivalent to start() but requires a specific runner instance which holds state of interest. This method is intended to be called from the TaskRunner's lifecycle

Specified by:

startManagement in interface ResourceManagementStrategy<WorkerTaskRunner>

Parameters:

runner - The TaskRunner state holder this strategy should use during execution

stopManagement

public void stopManagement()

Description copied from interface: ResourceManagementStrategy

Equivalent to stop() Should be called from TaskRunner's lifecycle

Specified by:

stopManagement in interface ResourceManagementStrategy<WorkerTaskRunner>