io.druid.indexing.overlord.autoscaling

Class PendingTaskBasedWorkerProvisioningStrategy

java.lang.Object

io.druid.indexing.overlord.autoscaling.AbstractWorkerProvisioningStrategy

io.druid.indexing.overlord.autoscaling.PendingTaskBasedWorkerProvisioningStrategy

All Implemented Interfaces:

ProvisioningStrategy<WorkerTaskRunner>

public class PendingTaskBasedWorkerProvisioningStrategy
extends AbstractWorkerProvisioningStrategy

Constructor Summary

Constructors

Constructor and Description
PendingTaskBasedWorkerProvisioningStrategy(PendingTaskBasedWorkerProvisioningConfig config, com.google.common.base.Supplier<WorkerBehaviorConfig> workerConfigRef, ProvisioningSchedulerConfig provisioningSchedulerConfig)
PendingTaskBasedWorkerProvisioningStrategy(PendingTaskBasedWorkerProvisioningConfig config, com.google.common.base.Supplier<WorkerBehaviorConfig> workerConfigRef, ProvisioningSchedulerConfig provisioningSchedulerConfig, com.google.common.base.Supplier<ScheduledExecutorService> execFactory)

Method Summary

Modifier and Type	Method and Description
Provisioner	makeProvisioner(WorkerTaskRunner runner)

Methods inherited from class io.druid.indexing.overlord.autoscaling.AbstractWorkerProvisioningStrategy

makeProvisioningService

Methods inherited from class java.lang.Object

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

Constructor Detail

PendingTaskBasedWorkerProvisioningStrategy

@Inject
public PendingTaskBasedWorkerProvisioningStrategy(PendingTaskBasedWorkerProvisioningConfig config,
                                                          com.google.common.base.Supplier<WorkerBehaviorConfig> workerConfigRef,
                                                          ProvisioningSchedulerConfig provisioningSchedulerConfig)

PendingTaskBasedWorkerProvisioningStrategy

public PendingTaskBasedWorkerProvisioningStrategy(PendingTaskBasedWorkerProvisioningConfig config,
                                                  com.google.common.base.Supplier<WorkerBehaviorConfig> workerConfigRef,
                                                  ProvisioningSchedulerConfig provisioningSchedulerConfig,
                                                  com.google.common.base.Supplier<ScheduledExecutorService> execFactory)

Method Detail

makeProvisioner

public Provisioner makeProvisioner(WorkerTaskRunner runner)

Specified by:

makeProvisioner in class AbstractWorkerProvisioningStrategy