org.gridgain.grid
Interface GridNodeMetrics

All Superinterfaces:

Serializable

All Known Implementing Classes:

GridDiscoveryMetricsAdapter

@Apache20LicenseCompatible
public interface GridNodeMetrics
extends Serializable

This class represents runtime information on a node. Apart from obvious statistical value, this information is used for implementation of load balancing, failover, and collision SPIs. For example, collision SPI in combination with fail-over SPI could check if other nodes don't have any active or waiting jobs and fail-over some jobs to those nodes.

Node metrics for any node can be accessed via GridNode.getMetrics() method. Keep in mind that there will be a certain network delay (usually equal to heartbeat delay) for the accuracy of node metrics. However, when accessing metrics on local node Grid.getLocalNode().getMetrics() the metrics are always accurate and up to date.

Local node metrics are registered as MBean and can be accessed from any JMX management console. The simplest way is to use standard jconsole that comes with JDK as it also provides ability to view any node parameter as a graph.



See Also:

Documentation
Email Support
Online Forums
Issue Tracking

Author: 2005-2008 Copyright © GridGain Systems. All Rights Reserved. ver. 2.0.3

	Nikita Ivanov, GridGain Systems nivanov@gridgain.com
	Dmitriy Setrakyan, GridGain Systems dsetrakyan@gridgain.com
	Alexander Magdenko, GridGain Systems amagdenko@gridgain.com
	Boris Suchodoev, GridGain Systems bsuchodoev@gridgain.com
	Denis Kharlamov, GridGain Systems dkharlamov@gridgain.com
	close

Method Summary

int	getAvailableProcessors() Returns the number of processors available to the Java virtual machine.
float	getAverageActiveJobs() Gets average number of active jobs concurrently executing on the node.
float	getAverageCancelledJobs() Gets average number of cancelled jobs this node ever had running concurrently.
double	getAverageCpuLoad() Gets average of CPU load values over all metrics kept in the history.
double	getAverageJobExecuteTime() Gets average time a job takes to execute on the node.
double	getAverageJobWaitTime() Gets average time jobs spend waiting in the queue to be executed.
float	getAverageRejectedJobs() Gets average number of jobs this node rejects during collision resolution operations.
float	getAverageWaitingJobs() Gets average number of waiting jobs this node had queued.
float	getBusyTimePercentage() Gets percentage of time this node is busy executing jobs vs. idling.
int	getCurrentActiveJobs() Gets number of currently active jobs concurrently executing on the node.
int	getCurrentCancelledJobs() Gets number of cancelled jobs that are still running.
double	getCurrentCpuLoad() Returns the system load average for the last minute.
int	getCurrentDaemonThreadCount() Returns the current number of live daemon threads.
long	getCurrentIdleTime() Gets time this node spend idling since executing last job.
long	getCurrentJobExecuteTime() Gets longest time a current job has been executing for.
long	getCurrentJobWaitTime() Gets current time an oldest jobs has spent waiting to be executed.
int	getCurrentRejectedJobs() Gets number of jobs rejected after more recent collision resolution operation.
int	getCurrentThreadCount() Returns the current number of live threads including both daemon and non-daemon threads.
int	getCurrentWaitingJobs() Gets number of queued jobs currently waiting to be executed.
long	getHeapMemoryCommitted() Returns the amount of heap memory in bytes that is committed for the Java virtual machine to use.
long	getHeapMemoryInitialized() Returns the amount of heap memory in bytes that the Java virtual machine initially requests from the operating system for memory management.
long	getHeapMemoryMaximum() Returns the maximum amount of heap memory in bytes that can be used for memory management.
long	getHeapMemoryUsed() Returns the current heap size that is used for object allocation.
float	getIdleTimePercentage() Gets percentage of time this node is idling vs. executing jobs.
long	getLastUpdateTime() Gets last update time of this node metrics.
int	getMaximumActiveJobs() Gets maximum number of jobs that ever ran concurrently on this node.
int	getMaximumCancelledJobs() Gets maximum number of cancelled jobs this node ever had running concurrently.
long	getMaximumJobExecuteTime() Gets time it took to execute the longest job on the node.
long	getMaximumJobWaitTime() Gets maximum time a job ever spent waiting in a queue to be executed.
int	getMaximumRejectedJobs() Gets maximum number of jobs rejected at once during a single collision resolution operation.
int	getMaximumThreadCount() Returns the maximum live thread count since the Java virtual machine started or peak was reset.
int	getMaximumWaitingJobs() Gets maximum number of waiting jobs this node had.
long	getNonHeapMemoryCommitted() Returns the amount of non-heap memory in bytes that is committed for the Java virtual machine to use.
long	getNonHeapMemoryInitialized() Returns the amount of non-heap memory in bytes that the Java virtual machine initially requests from the operating system for memory management.
long	getNonHeapMemoryMaximum() Returns the maximum amount of non-heap memory in bytes that can be used for memory management.
long	getNonHeapMemoryUsed() Returns the current non-heap memory size that is used by Java VM.
long	getStartTime() Returns the start time of the Java virtual machine in milliseconds.
long	getTotalBusyTime() Gets total time this node spent executing jobs.
int	getTotalCancelledJobs() Gets total number of cancelled jobs.
int	getTotalExecutedJobs() Gets total number of jobs handled by the node.
long	getTotalIdleTime() Gets total time this node spent idling (not executing any jobs).
int	getTotalRejectedJobs() Gets total number of jobs this node rejects during collision resolution operations.
long	getTotalStartedThreadCount() Returns the total number of threads created and also started since the Java virtual machine started.
long	getUptime() Returns the uptime of the Java virtual machine in milliseconds.

Method Detail

getLastUpdateTime

long getLastUpdateTime()

Gets last update time of this node metrics.

Returns:

Last update time.

getMaximumActiveJobs

int getMaximumActiveJobs()

Gets maximum number of jobs that ever ran concurrently on this node. Note that this different from GridNodeMetrics.getTotalExecutedJobs() metric and only reflects maximum number of jobs that ran at the same time.

Note: all aggregated metrics like average, minimum, maximum, total, count are calculated over all the metrics kept in history. The history size is set via either one or both of configuration settings:

• GridConfiguration.getMetricsExpireTime()
• GridConfiguration.getMetricsHistorySize()

Returns:

Maximum number of jobs that ever ran concurrently on this node.

getCurrentActiveJobs

int getCurrentActiveJobs()

Gets number of currently active jobs concurrently executing on the node.

Returns:

Number of currently active jobs concurrently executing on the node.

getAverageActiveJobs

float getAverageActiveJobs()

Gets average number of active jobs concurrently executing on the node.

Note: all aggregated metrics like average, minimum, maximum, total, count are calculated over all the metrics kept in history. The history size is set via either one or both of configuration settings:

• GridConfiguration.getMetricsExpireTime()
• GridConfiguration.getMetricsHistorySize()

Returns:

Average number of active jobs.

getMaximumWaitingJobs

int getMaximumWaitingJobs()

Gets maximum number of waiting jobs this node had.

Note: all aggregated metrics like average, minimum, maximum, total, count are calculated over all the metrics kept in history. The history size is set via either one or both of configuration settings:

• GridConfiguration.getMetricsExpireTime()
• GridConfiguration.getMetricsHistorySize()

Returns:

Maximum number of waiting jobs.

getCurrentWaitingJobs

int getCurrentWaitingJobs()

Gets number of queued jobs currently waiting to be executed.

Returns:

Number of queued jobs currently waiting to be executed.

getAverageWaitingJobs

float getAverageWaitingJobs()

Gets average number of waiting jobs this node had queued.

Note: all aggregated metrics like average, minimum, maximum, total, count are calculated over all the metrics kept in history. The history size is set via either one or both of configuration settings:

• GridConfiguration.getMetricsExpireTime()
• GridConfiguration.getMetricsHistorySize()

Returns:

Average number of waiting jobs.

getMaximumRejectedJobs

int getMaximumRejectedJobs()

Gets maximum number of jobs rejected at once during a single collision resolution operation.

Note: all aggregated metrics like average, minimum, maximum, total, count are calculated over all the metrics kept in history. The history size is set via either one or both of configuration settings:

• GridConfiguration.getMetricsExpireTime()
• GridConfiguration.getMetricsHistorySize()

Returns:

Maximum number of jobs rejected at once.

getCurrentRejectedJobs

int getCurrentRejectedJobs()

Gets number of jobs rejected after more recent collision resolution operation.

Returns:

Number of jobs rejected after more recent collision resolution operation.

getAverageRejectedJobs

float getAverageRejectedJobs()

Gets average number of jobs this node rejects during collision resolution operations.

Note: all aggregated metrics like average, minimum, maximum, total, count are calculated over all the metrics kept in history. The history size is set via either one or both of grid configuration settings:

• GridConfiguration.getMetricsExpireTime()
• GridConfiguration.getMetricsHistorySize()

Returns:

Average number of jobs this node rejects during collision resolution operations.

getTotalRejectedJobs

int getTotalRejectedJobs()

Gets total number of jobs this node rejects during collision resolution operations.

Note: all aggregated metrics like average, minimum, maximum, total, count are calculated over all the metrics kept in history. The history size is set via either one or both of configuration settings:

• GridConfiguration.getMetricsExpireTime()
• GridConfiguration.getMetricsHistorySize()

Returns:

Total number of jobs this node rejects during collision resolution operations.

getMaximumCancelledJobs

int getMaximumCancelledJobs()

Gets maximum number of cancelled jobs this node ever had running concurrently.

Returns:

Maximum number of cancelled jobs.

getCurrentCancelledJobs

int getCurrentCancelledJobs()

Gets number of cancelled jobs that are still running. Just like regular java threads, jobs will receive cancel notification, but it's ultimately upto the job itself to gracefully exit.

Returns:

Number of cancelled jobs that are still running.

getAverageCancelledJobs

float getAverageCancelledJobs()

Gets average number of cancelled jobs this node ever had running concurrently.

Note: all aggregated metrics like average, minimum, maximum, total, count are calculated over all the metrics kept in history. The history size is set via either one or both of configuration settings:

• GridConfiguration.getMetricsExpireTime()
• GridConfiguration.getMetricsHistorySize()

Returns:

Average number of cancelled jobs.

getTotalExecutedJobs

int getTotalExecutedJobs()

Gets total number of jobs handled by the node.

Note: all aggregated metrics like average, minimum, maximum, total, count are calculated over all the metrics kept in history. The history size is set via either one or both of configuration settings:

• GridConfiguration.getMetricsExpireTime()
• GridConfiguration.getMetricsHistorySize()

Returns:

Total number of jobs handled by the node.

getTotalCancelledJobs

int getTotalCancelledJobs()

Gets total number of cancelled jobs.

Note: all aggregated metrics like average, minimum, maximum, total, count are calculated over all the metrics kept in history. The history size is set via either one or both of configuration settings:

• GridConfiguration.getMetricsExpireTime()
• GridConfiguration.getMetricsHistorySize()

Returns:

Total number of cancelled jobs since node startup.

getMaximumJobWaitTime

long getMaximumJobWaitTime()

Gets maximum time a job ever spent waiting in a queue to be executed.

Note: all aggregated metrics like average, minimum, maximum, total, count are calculated over all the metrics kept in history. The history size is set via either one or both of configuration settings:

• GridConfiguration.getMetricsExpireTime()
• GridConfiguration.getMetricsHistorySize()

Returns:

Maximum waiting time.

getCurrentJobWaitTime

long getCurrentJobWaitTime()

Gets current time an oldest jobs has spent waiting to be executed.

Returns:

Current wait time of oldest job.

getAverageJobWaitTime

double getAverageJobWaitTime()

Gets average time jobs spend waiting in the queue to be executed.

Note: all aggregated metrics like average, minimum, maximum, total, count are calculated over all the metrics kept in history. The history size is set via either one or both of configuration settings:

• GridConfiguration.getMetricsExpireTime()
• GridConfiguration.getMetricsHistorySize()

Returns:

Average job wait time.

getMaximumJobExecuteTime

long getMaximumJobExecuteTime()

Gets time it took to execute the longest job on the node.

Note: all aggregated metrics like average, minimum, maximum, total, count are calculated over all the metrics kept in history. The history size is set via either one or both of configuration settings:

• GridConfiguration.getMetricsExpireTime()
• GridConfiguration.getMetricsHistorySize()

Returns:

Time it took to execute the longest job on the node.

getCurrentJobExecuteTime

long getCurrentJobExecuteTime()

Gets longest time a current job has been executing for.

Returns:

Longest time a current job has been executing for.

getAverageJobExecuteTime

double getAverageJobExecuteTime()

Gets average time a job takes to execute on the node.

Note: all aggregated metrics like average, minimum, maximum, total, count are calculated over all the metrics kept in history. The history size is set via either one or both of configuration settings:

• GridConfiguration.getMetricsExpireTime()
• GridConfiguration.getMetricsHistorySize()

Returns:

Average job execution time.

getTotalBusyTime

long getTotalBusyTime()

Gets total time this node spent executing jobs.

Returns:

Total time this node spent executing jobs.

getTotalIdleTime

long getTotalIdleTime()

Gets total time this node spent idling (not executing any jobs).

Returns:

Gets total time this node spent idling.

getCurrentIdleTime

long getCurrentIdleTime()

Gets time this node spend idling since executing last job.

Returns:

Time this node spend idling since executing last job.

getBusyTimePercentage

float getBusyTimePercentage()

Gets percentage of time this node is busy executing jobs vs. idling.

Returns:

Percentage of time this node is busy (value is less than or equal to 1 and greater than or equal to 0)

getIdleTimePercentage

float getIdleTimePercentage()

Gets percentage of time this node is idling vs. executing jobs.

Returns:

Percentage of time this node is idle (value is less than or equal to 1 and greater than or equal to 0)

getAvailableProcessors

int getAvailableProcessors()

Returns the number of processors available to the Java virtual machine. This method is equivalent to the Runtime.availableProcessors() method.

This value may change during a particular invocation of the virtual machine.

Returns:

The number of processors available to the virtual machine; never smaller than one.

getCurrentCpuLoad

double getCurrentCpuLoad()

Returns the system load average for the last minute. The system load average is the sum of the number of runnable entities queued to the available processors and the number of runnable entities running on the available processors averaged over a period of time. The way in which the load average is calculated is operating system specific but is typically a damped time-dependent average.

If the load average is not available, a negative value is returned.

This method is designed to provide a hint about the system load and may be queried frequently. The load average may be unavailable on some platform where it is expensive to implement this method.

If you are running JDK 1.6 or above, then this method is equivalent to OperatingSystemMXBean.getSystemLoadAverage() method. Otherwise, for JDK 1.5 Hyperic CIGAR monitoring will be used. Note, however, that JDK 1.6 does not provide load average on some operating system (including Windows Vista) and in many cases provides wrong values. In such cases Hyperic Sigar should be used (which is default configuration) to provide proper system load average value.

Note that Hyperic CIGAR is licensed under GPL. If this license is not suitable for your business, remove hyperic libs from your classpath. In case if this method will not detect JDK 1.6 and will not find CIGAR libraries in the classpath, -1 will be returned.

Returns:

The system load average; or a negative value if not available.

getAverageCpuLoad

double getAverageCpuLoad()

Gets average of CPU load values over all metrics kept in the history.

Note: all aggregated metrics like average, minimum, maximum, total, count are calculated over all the metrics kept in history. The history size is set via either one or both of configuration settings:

• GridConfiguration.getMetricsExpireTime()
• GridConfiguration.getMetricsHistorySize()

Returns:

Average of CPU load values over all metrics kept in the history.

getHeapMemoryInitialized

long getHeapMemoryInitialized()

Returns the amount of heap memory in bytes that the Java virtual machine initially requests from the operating system for memory management. This method returns -1 if the initial memory size is undefined.

This value represents a setting of the heap memory for Java VM and is not a sum of all initial heap values for all memory pools.

Note: this is not an aggregated metric and it's calculated from the time of the node's startup.

Returns:

The initial size of memory in bytes; -1 if undefined.

getHeapMemoryUsed

long getHeapMemoryUsed()

Returns the current heap size that is used for object allocation. The heap consists of one or more memory pools. This value is the sum of used heap memory values of all heap memory pools.

The amount of used memory in the returned is the amount of memory occupied by both live objects and garbage objects that have not been collected, if any.

Note: this is not an aggregated metric and it's calculated from the time of the node's startup.

Returns:

Amount of heap memory used.

getHeapMemoryCommitted

long getHeapMemoryCommitted()

Returns the amount of heap memory in bytes that is committed for the Java virtual machine to use. This amount of memory is guaranteed for the Java virtual machine to use. The heap consists of one or more memory pools. This value is the sum of committed heap memory values of all heap memory pools.

Note: this is not an aggregated metric and it's calculated from the time of the node's startup.

Returns:

The amount of committed memory in bytes.

getHeapMemoryMaximum

long getHeapMemoryMaximum()

Returns the maximum amount of heap memory in bytes that can be used for memory management. This method returns -1 if the maximum memory size is undefined.

This amount of memory is not guaranteed to be available for memory management if it is greater than the amount of committed memory. The Java virtual machine may fail to allocate memory even if the amount of used memory does not exceed this maximum size.

This value represents a setting of the heap memory for Java VM and is not a sum of all initial heap values for all memory pools.

Note: this is not an aggregated metric and it's calculated from the time of the node's startup.

Returns:

The maximum amount of memory in bytes; -1 if undefined.

getNonHeapMemoryInitialized

long getNonHeapMemoryInitialized()

Returns the amount of non-heap memory in bytes that the Java virtual machine initially requests from the operating system for memory management. This method returns -1 if the initial memory size is undefined.

This value represents a setting of non-heap memory for Java VM and is not a sum of all initial heap values for all memory pools.

Note: this is not an aggregated metric and it's calculated from the time of the node's startup.

Returns:

The initial size of memory in bytes; -1 if undefined.

getNonHeapMemoryUsed

long getNonHeapMemoryUsed()

Returns the current non-heap memory size that is used by Java VM. The non-heap memory consists of one or more memory pools. This value is the sum of used non-heap memory values of all non-heap memory pools.

Note: this is not an aggregated metric and it's calculated from the time of the node's startup.

Note: this is not an aggregated metric and it's calculated from the time of the node's startup.

Returns:

Amount of none-heap memory used.

getNonHeapMemoryCommitted

long getNonHeapMemoryCommitted()

Returns the amount of non-heap memory in bytes that is committed for the Java virtual machine to use. This amount of memory is guaranteed for the Java virtual machine to use. The non-heap memory consists of one or more memory pools. This value is the sum of committed non-heap memory values of all non-heap memory pools.

Note: this is not an aggregated metric and it's calculated from the time of the node's startup.

Returns:

The amount of committed memory in bytes.

getNonHeapMemoryMaximum

long getNonHeapMemoryMaximum()

Returns the maximum amount of non-heap memory in bytes that can be used for memory management. This method returns -1 if the maximum memory size is undefined.

This amount of memory is not guaranteed to be available for memory management if it is greater than the amount of committed memory. The Java virtual machine may fail to allocate memory even if the amount of used memory does not exceed this maximum size.

This value represents a setting of the non-heap memory for Java VM and is not a sum of all initial non-heap values for all memory pools.

Note: this is not an aggregated metric and it's calculated from the time of the node's startup.

Returns:

The maximum amount of memory in bytes; -1 if undefined.

getUptime

long getUptime()

Returns the uptime of the Java virtual machine in milliseconds.

Returns:

Uptime of the Java virtual machine in milliseconds.

getStartTime

long getStartTime()

Returns the start time of the Java virtual machine in milliseconds. This method returns the approximate time when the Java virtual machine started.

Returns:

Start time of the Java virtual machine in milliseconds.

getCurrentThreadCount

int getCurrentThreadCount()

Returns the current number of live threads including both daemon and non-daemon threads.

Returns:

the current number of live threads.

getMaximumThreadCount

int getMaximumThreadCount()

Returns the maximum live thread count since the Java virtual machine started or peak was reset.

Note: this is not an aggregated metric and it's calculated from the time of the node's startup.

Returns:

The peak live thread count.

getTotalStartedThreadCount

long getTotalStartedThreadCount()

Returns the total number of threads created and also started since the Java virtual machine started.

Note: this is not an aggregated metric and it's calculated from the time of the node's startup.

Returns:

The total number of threads started.

getCurrentDaemonThreadCount

int getCurrentDaemonThreadCount()

Returns the current number of live daemon threads.

Returns:

The current number of live daemon threads.