teetime.stage.taskfarm

Class TaskFarmConfiguration<I,O,T extends ITaskFarmDuplicable<I,O>>

java.lang.Object

teetime.stage.taskfarm.TaskFarmConfiguration<I,O,T>

Type Parameters:

I - Input type of Task Farm

O - Output type of Task Farm

T - Type of enclosed stage

public class TaskFarmConfiguration<I,O,T extends ITaskFarmDuplicable<I,O>>
extends Object

Represents the configuration of a single Task Farm.

Author:

Christian Claus Wiechmann

Field Summary

Fields

Modifier and Type	Field and Description
static int	INIT_SAMPLES_UNTIL_REMOVE represents an initial value for the samples until remove for TaskFarmReconfigurationCommandService

Method Summary

Modifier and Type	Method and Description
int	getAdaptationWaitingTimeMillis()
int	getAnalysisWindow()
int	getMaxNumberOfCores()
int	getMaxSamplesUntilRemove()
int	getPipeCapacity()
String	getThroughputAlgorithm()
double	getThroughputScoreBoundary()
WeightedAlgorithm.WeightMethod	getWeightedAlgorithmMethod()
boolean	isMonitoringEnabled()
void	setAdaptationWaitingTimeMillis(int adaptationWaitingTimeMillis)
void	setAnalysisWindow(int analysisWindow)
void	setMaxNumberOfCores(int maxNumberOfCores)
void	setMaxSamplesUntilRemove(int maxSamplesUntilRemove)
void	setMonitoringEnabled(boolean monitoringEnabled)
void	setPipeCapacity(int pipeCapacity)
void	setThroughputAlgorithm(String throughputAlgorithm)
void	setThroughputScoreBoundary(double throughputScoreBoundary)
void	setWeightedAlgorithmMethod(WeightedAlgorithm.WeightMethod weightedAlgorithmMethod)

Methods inherited from class java.lang.Object

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

Field Detail

INIT_SAMPLES_UNTIL_REMOVE

public static final int INIT_SAMPLES_UNTIL_REMOVE

represents an initial value for the samples until remove for TaskFarmReconfigurationCommandService

See Also:

Constant Field Values

Method Detail

getAnalysisWindow

public int getAnalysisWindow()

Returns:

the amount of previous measurements used by the throughput algorithm

setAnalysisWindow

public void setAnalysisWindow(int analysisWindow)

Parameters:

analysisWindow - the amount of previous measurements used by the throughput algorithm

getThroughputAlgorithm

public String getThroughputAlgorithm()

Returns:

used throughput algorithm (has to exist in the package teetime.stage.taskfarm.adaptation.analysis.algorithm)

setThroughputAlgorithm

public void setThroughputAlgorithm(String throughputAlgorithm)

Parameters:

throughputAlgorithm - used throughput algorithm (has to exist in the package teetime.stage.taskfarm.adaptation.analysis.algorithm)

getWeightedAlgorithmMethod

public WeightedAlgorithm.WeightMethod getWeightedAlgorithmMethod()

Returns:

if the WeightedAlgorithm is used as the throughput algorithm, this WeightMethod is used

setWeightedAlgorithmMethod

public void setWeightedAlgorithmMethod(WeightedAlgorithm.WeightMethod weightedAlgorithmMethod)

Parameters:

weightedAlgorithmMethod - if the WeightedAlgorithm is used as the throughput algorithm, this WeightMethod is used

getMaxSamplesUntilRemove

public int getMaxSamplesUntilRemove()

Returns:

the TaskFarmReconfigurationCommandService waits this amount of adaptation thread iterations for performance improvements after a new worker stage is added

setMaxSamplesUntilRemove

public void setMaxSamplesUntilRemove(int maxSamplesUntilRemove)

Parameters:

maxSamplesUntilRemove - the TaskFarmReconfigurationCommandService waits this amount of adaptation thread iterations for performance improvements after a new worker stage is added

getThroughputScoreBoundary

public double getThroughputScoreBoundary()

Returns:

throughput boundary of this task farm

setThroughputScoreBoundary

public void setThroughputScoreBoundary(double throughputScoreBoundary)

Parameters:

throughputScoreBoundary - throughput boundary of this task farm

isMonitoringEnabled

public boolean isMonitoringEnabled()

Returns:

should the monitoring services be activated (does not affect the adaptation thread!)?

setMonitoringEnabled

public void setMonitoringEnabled(boolean monitoringEnabled)

Parameters:

monitoringEnabled - should the monitoring services be activated (does not affect the adaptation thread!)?

getAdaptationWaitingTimeMillis

public int getAdaptationWaitingTimeMillis()

Returns:

the waiting time between each iteration of the adaptation thread

setAdaptationWaitingTimeMillis

public void setAdaptationWaitingTimeMillis(int adaptationWaitingTimeMillis)

Parameters:

adaptationWaitingTimeMillis - the waiting time between each iteration of the adaptation thread

getPipeCapacity

public int getPipeCapacity()

Returns:

pipe capacity of all pipes inside the task farm

setPipeCapacity

public void setPipeCapacity(int pipeCapacity)

Parameters:

pipeCapacity - pipe capacity of all pipes inside the task farm

getMaxNumberOfCores

public int getMaxNumberOfCores()

Returns:

the maximum number of worker stages the task farm may have

setMaxNumberOfCores

public void setMaxNumberOfCores(int maxNumberOfCores)

Parameters:

maxNumberOfCores - the maximum number of worker stages the task farm may have