Package io.aleph.dirigiste

Class Stats

java.lang.Object

io.aleph.dirigiste.Stats

public class Stats
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static enum	Stats.Metric
static class	Stats.UniformDoubleReservoir
static class	Stats.UniformDoubleReservoirMap<K>
static class	Stats.UniformLongReservoir
static class	Stats.UniformLongReservoirMap<K>

Field Summary

Fields

Modifier and Type	Field	Description
static final Stats	EMPTY

Constructor Summary

Constructors

Constructor	Description
Stats(EnumSet<Stats.Metric> metrics, int numWorkers, double[] utilizations, double[] taskArrivalRates, double[] taskCompletionRates, double[] taskRejectionRates, long[] queueLengths, long[] queueLatencies, long[] taskLatencies)

Method Summary

Modifier and Type	Method	Description
double	getMeanQueueLatency()
double	getMeanQueueLength()
double	getMeanTaskArrivalRate()
double	getMeanTaskCompletionRate()
double	getMeanTaskLatency()
double	getMeanTaskRejectionRate()
double	getMeanUtilization()
EnumSet<Stats.Metric>	getMetrics()
int	getNumWorkers()
double	getQueueLatency(double quantile)
double	getQueueLength(double quantile)
double	getTaskArrivalRate(double quantile)
double	getTaskCompletionRate(double quantile)
double	getTaskLatency(double quantile)
double	getTaskRejectionRate(double quantile)
double	getUtilization(double quantile)
static double	lerp(double[] vals, double t)
static double	lerp(double low, double high, double t)
static double	lerp(long[] vals, double t)
static double	lerp(long low, long high, double t)
static double	mean(double[] vals)
static double	mean(long[] vals)

Methods inherited from class java.lang.Object

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

Field Details

EMPTY

public static final Stats EMPTY

Constructor Details

Stats

public Stats(EnumSet<Stats.Metric> metrics,
 int numWorkers,
 double[] utilizations,
 double[] taskArrivalRates,
 double[] taskCompletionRates,
 double[] taskRejectionRates,
 long[] queueLengths,
 long[] queueLatencies,
 long[] taskLatencies)

Method Details

lerp

public static double lerp(long low,
 long high,
 double t)

lerp

public static double lerp(double low,
 double high,
 double t)

lerp

public static double lerp(long[] vals,
 double t)

lerp

public static double lerp(double[] vals,
 double t)

mean

public static double mean(double[] vals)

mean

public static double mean(long[] vals)

getMetrics

public EnumSet<Stats.Metric> getMetrics()

Returns:

the provided metrics

getNumWorkers

public int getNumWorkers()

Returns:

the number of active workers in the pool.

getMeanUtilization

public double getMeanUtilization()

Returns:

the mean utilization of the workers as a value between 0 and 1.

getUtilization

public double getUtilization(double quantile)

Parameters:

quantile - the point within the distribution to look up, 0.5 returns the median, 0.9 the 90th percentile

Returns:

the utilization of the workers as a value between 0 and 1

getMeanTaskArrivalRate

public double getMeanTaskArrivalRate()

Returns:

the mean task arrival rate of the executor, in tasks per second

getTaskArrivalRate

public double getTaskArrivalRate(double quantile)

Parameters:

quantile - the point within the distribution to look up, 0.5 returns the median, 0.9 the 90th percentile

Returns:

the task arrival rate of the executor, in tasks per second

getMeanTaskCompletionRate

public double getMeanTaskCompletionRate()

Returns:

the mean task completion rate of the executor, in tasks per second

getTaskCompletionRate

public double getTaskCompletionRate(double quantile)

Parameters:

quantile - the point within the distribution to look up, 0.5 returns the median, 0.9 the 90th percentile

Returns:

the task completion rate of the executor, in tasks per second

getMeanTaskRejectionRate

public double getMeanTaskRejectionRate()

Returns:

the mean task rejection rate of the executor, in tasks per second

getTaskRejectionRate

public double getTaskRejectionRate(double quantile)

Parameters:

quantile - the point within the distribution to look up, 0.5 returns the median, 0.9 the 90th percentile

Returns:

the task rejection rate of the executor, in tasks per second

getMeanQueueLength

public double getMeanQueueLength()

Returns:

the mean length of the queue

getQueueLength

public double getQueueLength(double quantile)

Parameters:

quantile - the point within the distribution to look up, 0.5 returns the median, 0.9 the 90th percentile

Returns:

the length of the queue

getMeanQueueLatency

public double getMeanQueueLatency()

Returns:

the mean time each task spends on the queue, in nanoseconds

getQueueLatency

public double getQueueLatency(double quantile)

Parameters:

quantile - the point within the distribution to look up, 0.5 returns the median, 0.9 the 90th percentile

Returns:

the time each task spends on the queue, in nanoseconds

getMeanTaskLatency

public double getMeanTaskLatency()

Returns:

the mean time each task takes to complete, including time on the queue, in nanoseconds

getTaskLatency

public double getTaskLatency(double quantile)

Parameters:

quantile - the point within the distribution to look up, 0.5 returns the median, 0.9 the 90th percentile

Returns:

the time each task takes to complete, including time on the queue, in nanoseconds