alluxio.stress.worker

Class WorkerBenchCoarseDataPoint

java.lang.Object

alluxio.stress.worker.WorkerBenchCoarseDataPoint

public class WorkerBenchCoarseDataPoint
extends Object

One coarseDataPoint captures and merges the performance of I/O operations in a specified window. The I/O operations are grouped by worker and by thread. In other words, I/O operations in a window in different threads will be recorded in different coarse data points.

Constructor Summary

Constructors

Constructor and Description
WorkerBenchCoarseDataPoint(Long workerID, Long threadID) Creates a coarse data point without data and throughput arrays.
WorkerBenchCoarseDataPoint(Long workerID, Long threadID, List<WorkerBenchDataPoint> data, List<Long> throughput) Creates a coarse data point with data and throughput arrays.

Method Summary

Modifier and Type	Method and Description
void	addDataPoint(WorkerBenchDataPoint data)
void	clearThroughput() removes the list of all throughput after worker aggregation.
List<WorkerBenchDataPoint>	getData()
List<Long>	getThroughput()
Long	getTid()
Long	getWid()
void	setData(List<WorkerBenchDataPoint> data)
void	setThroughput(List<Long> throughput)
void	setTid(Long tid)
void	setWid(Long wid)

Methods inherited from class java.lang.Object

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

Constructor Detail

WorkerBenchCoarseDataPoint

public WorkerBenchCoarseDataPoint(Long workerID,
                                  Long threadID)

Creates a coarse data point without data and throughput arrays.

Parameters:

workerID - the ID of the worker

threadID - the ID of the thread

WorkerBenchCoarseDataPoint

public WorkerBenchCoarseDataPoint(Long workerID,
                                  Long threadID,
                                  List<WorkerBenchDataPoint> data,
                                  List<Long> throughput)

Creates a coarse data point with data and throughput arrays.

Parameters:

workerID - the ID of the worker

threadID - the ID of the thread

data - the list of data point lists

throughput - the list of throughput

Method Detail

getWid

public Long getWid()

Returns:

the ID of the worker

setWid

public void setWid(Long wid)

Parameters:

wid - the ID of the worker

getTid

public Long getTid()

Returns:

the ID of the thread

setTid

public void setTid(Long tid)

Parameters:

tid - the ID of the thread

getData

public List<WorkerBenchDataPoint> getData()

Returns:

the list of data point lists

setData

public void setData(List<WorkerBenchDataPoint> data)

Parameters:

data - the list of data point lists

addDataPoint

public void addDataPoint(WorkerBenchDataPoint data)

Parameters:

data - add a data point list to the list of data point lists

getThroughput

public List<Long> getThroughput()

Returns:

the list of all throughput

setThroughput

public void setThroughput(List<Long> throughput)

Parameters:

throughput - the list of all throughput

clearThroughput

public void clearThroughput()

removes the list of all throughput after worker aggregation.