io.druid.indexing.overlord.autoscaling

Class AbstractWorkerProvisioningStrategy

java.lang.Object

io.druid.indexing.overlord.autoscaling.AbstractWorkerProvisioningStrategy

All Implemented Interfaces:

ProvisioningStrategy<WorkerTaskRunner>

Direct Known Subclasses:

PendingTaskBasedWorkerProvisioningStrategy, SimpleWorkerProvisioningStrategy

public abstract class AbstractWorkerProvisioningStrategy
extends Object
implements ProvisioningStrategy<WorkerTaskRunner>

Method Summary

Modifier and Type	Method and Description
protected abstract Provisioner	makeProvisioner(WorkerTaskRunner runner)
ProvisioningService	makeProvisioningService(WorkerTaskRunner runner) Creates a new ProvisioningService for the given TaskRunner This method is intended to be called from the TaskRunner's lifecycle start

Methods inherited from class java.lang.Object

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

Method Detail

makeProvisioningService

public ProvisioningService makeProvisioningService(WorkerTaskRunner runner)

Description copied from interface: ProvisioningStrategy

Creates a new ProvisioningService for the given TaskRunner This method is intended to be called from the TaskRunner's lifecycle start

Specified by:

makeProvisioningService in interface ProvisioningStrategy<WorkerTaskRunner>

Parameters:

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

makeProvisioner

protected abstract Provisioner makeProvisioner(WorkerTaskRunner runner)