alluxio.master.throttle

Class ServerIndicator

java.lang.Object

alluxio.master.throttle.ServerIndicator

public class ServerIndicator
extends Object

The server indicators. It can be used as a point-in-time indicator, an aggregated indicator, a single threshold indicator or aggregated threshold. For several PIT indicators can be aggregated, the addition function can be used for that. For one indicator can also be reduced, the reduction function can be used. One example is the sliding window: aggregated indicator1 = ( pit1 + pit2 + pit3) aggregated indicator2 = (aggregated indicator1 + pit4 - pit1)

Constructor Summary

Constructors

Constructor and Description
ServerIndicator(long directMemUsed, long heapMax, long heapUsed, double cpuLoad, long totalJVMPauseTimeMS, long pitTotalJVMPauseTimeMS, long rpcQueueSize, long snapshotTimeMS)
ServerIndicator(ServerIndicator serverIndicator)
ServerIndicator(ServerIndicator serverIndicator, int multiple) The scaled server indicator according to the multiple.

Method Summary

Modifier and Type	Method and Description
void	addition(ServerIndicator serverIndicator) Addition the server indicator object.
static ServerIndicator	createFromMetrics(long prevTotalJVMPauseTime) Creates a server indicator based on current status.
static ServerIndicator	createThresholdIndicator(long directMemUsed, double ratioOfUsedHeap, double cpuLoad, long totalJVMPauseTimeMS, long rpcQueueSize) Creates a threshold indicator object, the parameters are set according the input values.
double	getCpuLoad()
long	getDirectMemUsed()
long	getHeapMax()
long	getHeapUsed()
long	getPitTimeMS()
long	getPITTotalJVMPauseTimeMS()
long	getRpcQueueSize()
static long	getSystemTotalJVMPauseTime()
long	getTotalJVMPauseTimeMS()
void	reduction(ServerIndicator serverIndicator) Gets the server indicator after reducing the serverIndicator.
void	setPitTimeMS(long pitTimeMS) Sets the pit time.
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

ServerIndicator

public ServerIndicator(long directMemUsed,
                       long heapMax,
                       long heapUsed,
                       double cpuLoad,
                       long totalJVMPauseTimeMS,
                       long pitTotalJVMPauseTimeMS,
                       long rpcQueueSize,
                       long snapshotTimeMS)

Parameters:

directMemUsed - the allocated direct memory

heapMax - the max heap

heapUsed - the used heap

cpuLoad - the cpu load

totalJVMPauseTimeMS - the total JVM pause time since previous PIT

pitTotalJVMPauseTimeMS - the pit total JVM pause time

rpcQueueSize - the pit rpc queue size

snapshotTimeMS - the pit time

ServerIndicator

public ServerIndicator(ServerIndicator serverIndicator)

Parameters:

serverIndicator - the server indicator

ServerIndicator

public ServerIndicator(ServerIndicator serverIndicator,
                       int multiple)

The scaled server indicator according to the multiple. The threshold is set for single point in time value, and sometimes the sliding window is used to check if the threshold is crossed, in that case multiple times of single pit threshold is required. Eg, if the sliding window side is 3, (pit1, pit2, pit3), (pit2, pit3, pit4) ... are calculated. The threshold value * 3 would be used to check the value of sliding window. This constructor is helping generate the threshold of sliding window.

Parameters:

serverIndicator - the base server indicator

multiple - the times

Method Detail

getSystemTotalJVMPauseTime

public static long getSystemTotalJVMPauseTime()

Returns:

current total JVM pause time

createFromMetrics

public static ServerIndicator createFromMetrics(long prevTotalJVMPauseTime)

Creates a server indicator based on current status.

Parameters:

prevTotalJVMPauseTime - the previous total JVM pause time

Returns:

the server indicator

createThresholdIndicator

public static ServerIndicator createThresholdIndicator(long directMemUsed,
                                                       double ratioOfUsedHeap,
                                                       double cpuLoad,
                                                       long totalJVMPauseTimeMS,
                                                       long rpcQueueSize)

Creates a threshold indicator object, the parameters are set according the input values.

Parameters:

directMemUsed - the used direct mem

ratioOfUsedHeap - the ratio of used heap

cpuLoad - the cpu load

totalJVMPauseTimeMS - the total JVM pause time

rpcQueueSize - the rpc queue size

Returns:

the threshold indicator object

getDirectMemUsed

public long getDirectMemUsed()

Returns:

the direct mem used

getHeapMax

public long getHeapMax()

Returns:

the max heap

getHeapUsed

public long getHeapUsed()

Returns:

the used heap

getCpuLoad

public double getCpuLoad()

Returns:

the cpu load

getTotalJVMPauseTimeMS

public long getTotalJVMPauseTimeMS()

Returns:

the total JVM pause time

getPITTotalJVMPauseTimeMS

public long getPITTotalJVMPauseTimeMS()

Returns:

the PIT total JVM pause time

getRpcQueueSize

public long getRpcQueueSize()

Returns:

the rpc queue size

getPitTimeMS

public long getPitTimeMS()

Returns:

the time to measure the indicators

setPitTimeMS

public void setPitTimeMS(long pitTimeMS)

Sets the pit time.

Parameters:

pitTimeMS - the pit time

addition

public void addition(ServerIndicator serverIndicator)

Addition the server indicator object.

Parameters:

serverIndicator - the server indicator

reduction

public void reduction(ServerIndicator serverIndicator)

Gets the server indicator after reducing the serverIndicator. It can be used in sliding window calculation, eg: Aggregated1 = indicator1 + indicator2 + indicator3 Aggregated2 = Aggregated1 - indicator1 + indicator4

Parameters:

serverIndicator - the base server indicator

toString

public String toString()

Overrides:

toString in class Object

Returns:

the string object