com.orientechnologies.orient.core.storage.impl.local.statistic

Class OPerformanceStatisticManager

java.lang.Object

com.orientechnologies.orient.core.storage.impl.local.statistic.OPerformanceStatisticManager

public class OPerformanceStatisticManager
extends Object

Aggregator of performance statistic for whole storage. Allows to gather performance statistic for single thread or for all threads in storage.

In case of gathering statistics for single thread statistic for all period is gathered and average values are provided. If you gather statistic for whole system time series of measurements are provided.

You can not measure statistic for whole system and for chosen threads at the same time.

To gather statistic for single thread use following workflow:

1. Call startThreadMonitoring()
2. Execute database commands
3. Call stopThreadMonitoring()

Instance of OSessionStoragePerformanceStatistic returned as result of call of last method will contain all performance data are gathered during storage monitoring.

To gather statistic for whole system use following workflow:

1. Call startMonitoring()
2. During monitoring of storage use getXXX methods to get information about performance numbers
3. At the end of monitoring call stopMonitoring()

You may access performance data both after you stopped gathering statistic and during gathering of statistic. You may manipulate by manager directly from Java or from JMX from bean with name which consist of prefix MBEAN_PREFIX and storage name.

If ODurableComponent participates in performance monitoring it has to register itself using method registerComponent(String)

Field Summary

Fields

Modifier and Type	Field and Description
static String	MBEAN_PREFIX Prefix of name of JMX bean.

Constructor Summary

Constructors

Constructor and Description
OPerformanceStatisticManager(OAbstractPaginatedStorage storage, long intervalBetweenSnapshots, long cleanUpInterval)

Method Summary

Modifier and Type	Method and Description
long	getAmountOfPagesPerOperation(String componentName) Average amount of pages which were read from cache for component with given name during single data operation.
int	getCacheHits()
int	getCacheHits(String componentName) Percent of cache hits for component name of which is passed as method argument.
long	getCommitTime()
Set<String>	getComponentNames()
long	getExclusiveWriteCacheSize()
long	getFullCheckpointCount()
long	getFullCheckpointTime()
long	getReadCacheSize()
long	getReadSpeedFromCacheInPages()
long	getReadSpeedFromCacheInPages(String componentName) Read speed of data in pages per second on cache level for component name of which is passed as method argument.
long	getReadSpeedFromFileInPages()
long	getReadSpeedFromFileInPages(String componentName) Read speed of data from file system in pages for component name of which is passed as method argument.
OSessionStoragePerformanceStatistic	getSessionPerformanceStatistic()
long	getWALCacheOverflowCount()
long	getWALFlushTime()
long	getWALLogRecordTime()
long	getWALSize()
long	getWALStartAOLogRecordTime()
long	getWALStopAOLogRecordTime()
long	getWriteCacheFlushOperationsTime()
long	getWriteCacheFuzzyCheckpointTime()
long	getWriteCacheOverflowCount()
long	getWriteCachePagesPerFlush()
long	getWriteCacheSize()
long	getWriteSpeedInCacheInPages()
long	getWriteSpeedInCacheInPages(String componentName) Write speed of data in pages per second on cache level for component name of which is passed as method argument.
void	registerComponent(String component) Registers component as such one which participates in performance monitoring.
void	registerMBean(String storageName, int storageId) Registers JMX bean for current manager.
void	startMonitoring() Starts performance monitoring only for whole system.
void	startThreadMonitoring() Starts performance monitoring only for single thread.
void	stopMonitoring() Stops monitoring of performance statistic for whole system.
OSessionStoragePerformanceStatistic	stopThreadMonitoring()
void	unregisterMBean(String storageName, int storageId) Deregisters JMX bean for current manager.

Methods inherited from class java.lang.Object

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

Field Detail

MBEAN_PREFIX

public static final String MBEAN_PREFIX

Prefix of name of JMX bean.

See Also:

Constant Field Values

Constructor Detail

OPerformanceStatisticManager

public OPerformanceStatisticManager(OAbstractPaginatedStorage storage,
                                    long intervalBetweenSnapshots,
                                    long cleanUpInterval)

Parameters:

intervalBetweenSnapshots - Interval between snapshots of performance data for each thread statistic.

cleanUpInterval - Interval between time series of performance data.

See Also:

OSessionStoragePerformanceStatistic

Method Detail

startThreadMonitoring

public void startThreadMonitoring()

Starts performance monitoring only for single thread. After call of this method you can not start system wide monitoring till call of stopThreadMonitoring() is performed.

stopThreadMonitoring

public OSessionStoragePerformanceStatistic stopThreadMonitoring()

Returns:

Container for gathered performance statistic or null if startThreadMonitoring() is not called.

startMonitoring

public void startMonitoring()

Starts performance monitoring only for whole system.

After call of this method you can not start monitoring on thread level till call of stopMonitoring() is performed.

stopMonitoring

public void stopMonitoring()

Stops monitoring of performance statistic for whole system.

registerMBean

public void registerMBean(String storageName,
                          int storageId)

Registers JMX bean for current manager.

Parameters:

storageName - Name of storage of given manager

storageId - Id of storage of given manager

See Also:

OStorage.getName(), OIdentifiableStorage.getId()

unregisterMBean

public void unregisterMBean(String storageName,
                            int storageId)

Deregisters JMX bean for current manager.

Parameters:

storageName - Name of storage of given manager

storageId - Id of storage of given manager

See Also:

OStorage.getName(), OIdentifiableStorage.getId()

registerComponent

public void registerComponent(String component)

Registers component as such one which participates in performance monitoring.

Parameters:

component - Component which participates in performance monitoring.

getComponentNames

public Set<String> getComponentNames()

Returns:

Set of names of components for which performance statistic is gathered.

getSessionPerformanceStatistic

public OSessionStoragePerformanceStatistic getSessionPerformanceStatistic()

Returns:

Instance of performance container which is used to gathering data about storage performance statistic or null if none of both methods startMonitoring() or startThreadMonitoring() are called.

getAmountOfPagesPerOperation

public long getAmountOfPagesPerOperation(String componentName)

Average amount of pages which were read from cache for component with given name during single data operation.

If null value is passed or data for component with passed in name does not exist then -1 will be returned.

Parameters:

componentName - Name of component data of which should be returned. Name is case sensitive.

Returns:

Average amount of pages which were read from cache for component with given name during single data operation or value which is less than 0, which means that value cannot be calculated.

getCacheHits

public int getCacheHits()

Returns:

Percent of cache hits or value which is less than 0, which means that value cannot be calculated.

getCacheHits

public int getCacheHits(String componentName)

Percent of cache hits for component name of which is passed as method argument. If null value is passed then value for whole system will be returned. If data for component with passed in name does not exist then -1 will be returned.

Parameters:

componentName - Name of component data of which should be returned. Name is case sensitive.

Returns:

Percent of cache hits or value which is less than 0, which means that value cannot be calculated.

getCommitTime

public long getCommitTime()

Returns:

Average time of commit of atomic operation in nanoseconds or value which is less than 0, which means that value cannot be calculated.

getReadSpeedFromCacheInPages

public long getReadSpeedFromCacheInPages()

Returns:

Read speed of data in pages per second on cache level or value which is less than 0, which means that value cannot be calculated.

getReadSpeedFromCacheInPages

public long getReadSpeedFromCacheInPages(String componentName)

Read speed of data in pages per second on cache level for component name of which is passed as method argument. If null value is passed then value for whole system will be returned. If data for component with passed in name does not exist then -1 will be returned.

Parameters:

componentName - Name of component data of which should be returned. Name is case sensitive.

Returns:

Read speed of data in pages per second on cache level or value which is less than 0, which means that value cannot be calculated.

getReadSpeedFromFileInPages

public long getReadSpeedFromFileInPages()

Returns:

Read speed of data from file system in pages per second or value which is less than 0, which means that value cannot be calculated.

getReadSpeedFromFileInPages

public long getReadSpeedFromFileInPages(String componentName)

Read speed of data from file system in pages for component name of which is passed as method argument. If null value is passed then value for whole system will be returned. If data for component with passed in name does not exist then -1 will be returned.

Parameters:

componentName - Name of component data of which should be returned. Name is case sensitive.

Returns:

Read speed of data from file system in pages per second or value which is less than 0, which means that value cannot be calculated.

getWriteSpeedInCacheInPages

public long getWriteSpeedInCacheInPages()

Returns:

Write speed of data in pages per second on cache level or value which is less than 0, which means that value cannot be calculated.

getWriteSpeedInCacheInPages

public long getWriteSpeedInCacheInPages(String componentName)

Write speed of data in pages per second on cache level for component name of which is passed as method argument. If null value is passed then value for whole system will be returned. If data for component with passed in name does not exist then -1 will be returned.

Parameters:

componentName - Name of component data of which should be returned. Name is case sensitive.

Returns:

Write speed of data in pages per second on cache level or value which is less than 0, which means that value cannot be calculated.

getWriteCachePagesPerFlush

public long getWriteCachePagesPerFlush()

Returns:

Amount of pages which are flushed during "page flush" operation of write cache or -1 if value is undefined.

getWriteCacheFlushOperationsTime

public long getWriteCacheFlushOperationsTime()

Returns:

Amount of time which is spent on each "page flush" operation of write cache or -1 if value is undefined.

getWriteCacheFuzzyCheckpointTime

public long getWriteCacheFuzzyCheckpointTime()

Returns:

Amount of time which is spent on "fuzzy checkpoint" operation or -1 if value if undefined.

getFullCheckpointTime

public long getFullCheckpointTime()

Returns:

Time which is spent on full checkpoint operation, or -1 if value is undefined

getFullCheckpointCount

public long getFullCheckpointCount()

Returns:

Amount of times full checkpoint operations is called on storage, or -1 if this value is undefined.

getReadCacheSize

public long getReadCacheSize()

Returns:

Size of read cache in bytes or -1 if value is undefined.

getWriteCacheSize

public long getWriteCacheSize()

Returns:

Size of write cache in bytes or -1 if value is undefined.

getExclusiveWriteCacheSize

public long getExclusiveWriteCacheSize()

Returns:

Size of part of write cache which exclusively belongs to only this cache or -1 if value is undefined

getWriteCacheOverflowCount

public long getWriteCacheOverflowCount()

Returns:

Amount of times when size of write cache is not enough to keep dirty pages and flush of write cache is forced, or -1 if this value is undefined.

getWALSize

public long getWALSize()

Returns:

Size of WAL in bytes or -1 if value is undefined

getWALCacheOverflowCount

public long getWALCacheOverflowCount()

Returns:

Amount of times when WAL cache is completely filled in and force flush is needed or -1 if value is undefined

getWALLogRecordTime

public long getWALLogRecordTime()

Returns:

time which is spent on logging of single record or -1 if value is undefined.

getWALStartAOLogRecordTime

public long getWALStartAOLogRecordTime()

Returns:

Time which is spent on logging of "start atomic operation" record or -1 if value is undefined.

getWALStopAOLogRecordTime

public long getWALStopAOLogRecordTime()

Returns:

time which is spent on logging of "stop atomic operation" record or -1 if value is undefined.

getWALFlushTime

public long getWALFlushTime()

Returns:

time which is spent on flush of WAL cache or -1 if value is undefined