io.druid.indexing.overlord.autoscaling

Class SimpleWorkerResourceManagementConfig

java.lang.Object

io.druid.indexing.overlord.autoscaling.SimpleWorkerResourceManagementConfig

Direct Known Subclasses:

PendingTaskBasedWorkerResourceManagementConfig

public class SimpleWorkerResourceManagementConfig
extends Object

Constructor Summary

Constructors

Constructor and Description
SimpleWorkerResourceManagementConfig()

Method Summary

Modifier and Type	Method and Description
org.joda.time.Period	getMaxScalingDuration()
int	getNumEventsToTrack()
org.joda.time.Period	getPendingTaskTimeout()
org.joda.time.Period	getWorkerIdleTimeout()
int	getWorkerPort()
String	getWorkerVersion()
SimpleWorkerResourceManagementConfig	setMaxScalingDuration(org.joda.time.Period maxScalingDuration)
SimpleWorkerResourceManagementConfig	setNumEventsToTrack(int numEventsToTrack)
SimpleWorkerResourceManagementConfig	setPendingTaskTimeout(org.joda.time.Period pendingTaskTimeout)
SimpleWorkerResourceManagementConfig	setWorkerIdleTimeout(org.joda.time.Period workerIdleTimeout)
SimpleWorkerResourceManagementConfig	setWorkerPort(int workerPort)
SimpleWorkerResourceManagementConfig	setWorkerVersion(String workerVersion)

Methods inherited from class java.lang.Object

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

Constructor Detail

SimpleWorkerResourceManagementConfig

public SimpleWorkerResourceManagementConfig()

Method Detail

getWorkerIdleTimeout

public org.joda.time.Period getWorkerIdleTimeout()

setWorkerIdleTimeout

public SimpleWorkerResourceManagementConfig setWorkerIdleTimeout(org.joda.time.Period workerIdleTimeout)

getMaxScalingDuration

public org.joda.time.Period getMaxScalingDuration()

setMaxScalingDuration

public SimpleWorkerResourceManagementConfig setMaxScalingDuration(org.joda.time.Period maxScalingDuration)

getNumEventsToTrack

public int getNumEventsToTrack()

setNumEventsToTrack

public SimpleWorkerResourceManagementConfig setNumEventsToTrack(int numEventsToTrack)

getPendingTaskTimeout

public org.joda.time.Period getPendingTaskTimeout()

setPendingTaskTimeout

public SimpleWorkerResourceManagementConfig setPendingTaskTimeout(org.joda.time.Period pendingTaskTimeout)

getWorkerVersion

public String getWorkerVersion()

setWorkerVersion

public SimpleWorkerResourceManagementConfig setWorkerVersion(String workerVersion)

getWorkerPort

public int getWorkerPort()

setWorkerPort

public SimpleWorkerResourceManagementConfig setWorkerPort(int workerPort)