org.apache.ignite.internal.processors.cache.persistence

Class PersistenceMetricsImpl

java.lang.Object

org.apache.ignite.internal.processors.cache.persistence.PersistenceMetricsImpl

All Implemented Interfaces:

PersistenceMetricsMXBean, PersistenceMetrics

public class PersistenceMetricsImpl
extends Object
implements PersistenceMetricsMXBean

Constructor Summary

Constructors

Constructor and Description
PersistenceMetricsImpl(boolean metricsEnabled, long rateTimeInterval, int subInts)

Method Summary

Methods

Modifier and Type	Method and Description
void	disableMetrics() Disables persistence metrics collection on an Apache Ignite node.
void	enableMetrics() Enables persistence metrics collection on an Apache Ignite node.
long	getLastCheckpointCopiedOnWritePagesNumber() Gets the number of pages copied to a temporary checkpoint buffer during the last checkpoint.
long	getLastCheckpointDataPagesNumber() Gets the number of data pages written during the last checkpoint.
long	getLastCheckpointFsyncDuration() Gets the duration of the sync phase of the last checkpoint in milliseconds.
long	getLastCheckpointingDuration() Gets the duration of the last checkpoint in milliseconds.
long	getLastCheckpointLockWaitDuration() Gets the duration of last checkpoint lock wait in milliseconds.
long	getLastCheckpointMarkDuration() Gets the duration of last checkpoint mark phase in milliseconds.
long	getLastCheckpointPagesWriteDuration() Gets the duration of last checkpoint pages write phase in milliseconds.
long	getLastCheckpointTotalPagesNumber() Gets the total number of pages written during the last checkpoint.
int	getWalArchiveSegments() Gets the current number of WAL segments in the WAL archive.
float	getWalFsyncTimeAverage() Gets the average WAL fsync duration in microseconds over the last time interval.
float	getWalLoggingRate() Gets the average number of WAL records per second written during the last time interval.
float	getWalWritingRate() Gets the average number of bytes per second written during the last time interval.
boolean	metricsEnabled()
void	onCheckpoint(long lockWaitDuration, long markDuration, long pagesWriteDuration, long fsyncDuration, long duration, long totalPages, long dataPages, long cowPages)
void	onFsync(long nanoTime)
void	onWalBytesWritten(int size)
void	onWalRecordLogged()
void	rateTimeInterval(long rateTimeInterval) Sets time interval for rate-based metrics.
void	subIntervals(int subInts) Sets a number of sub-intervals the whole PersistenceMetricsMXBean.rateTimeInterval(long) will be split into to calculate rate-based metrics.
void	wal(IgniteWriteAheadLogManager wal)

Methods inherited from class java.lang.Object

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

Constructor Detail

PersistenceMetricsImpl

public PersistenceMetricsImpl(boolean metricsEnabled,
                      long rateTimeInterval,
                      int subInts)

Parameters:

metricsEnabled - Metrics enabled flag.

rateTimeInterval - Rate time interval.

subInts - Number of sub-intervals.

Method Detail

getWalLoggingRate

public float getWalLoggingRate()

Gets the average number of WAL records per second written during the last time interval.

The length of time interval is configured via PersistentStoreConfiguration.setRateTimeInterval(long) configurartion property. The number of subintervals is configured via PersistentStoreConfiguration.setSubIntervals(int) configuration property.

Specified by:

getWalLoggingRate in interface PersistenceMetricsMXBean

Specified by:

getWalLoggingRate in interface PersistenceMetrics

getWalWritingRate

public float getWalWritingRate()

Gets the average number of bytes per second written during the last time interval. The length of time interval is configured via PersistentStoreConfiguration.setRateTimeInterval(long) configurartion property. The number of subintervals is configured via PersistentStoreConfiguration.setSubIntervals(int) configuration property.

Specified by:

getWalWritingRate in interface PersistenceMetricsMXBean

Specified by:

getWalWritingRate in interface PersistenceMetrics

getWalArchiveSegments

public int getWalArchiveSegments()

Gets the current number of WAL segments in the WAL archive.

Specified by:

getWalArchiveSegments in interface PersistenceMetricsMXBean

Specified by:

getWalArchiveSegments in interface PersistenceMetrics

getWalFsyncTimeAverage

public float getWalFsyncTimeAverage()

Gets the average WAL fsync duration in microseconds over the last time interval.

The length of time interval is configured via PersistentStoreConfiguration.setRateTimeInterval(long) configurartion property. The number of subintervals is configured via PersistentStoreConfiguration.setSubIntervals(int) configuration property.

Specified by:

getWalFsyncTimeAverage in interface PersistenceMetricsMXBean

Specified by:

getWalFsyncTimeAverage in interface PersistenceMetrics

getLastCheckpointingDuration

public long getLastCheckpointingDuration()

Gets the duration of the last checkpoint in milliseconds.

Specified by:

getLastCheckpointingDuration in interface PersistenceMetricsMXBean

Specified by:

getLastCheckpointingDuration in interface PersistenceMetrics

Returns:

Total checkpoint duration in milliseconds.

getLastCheckpointLockWaitDuration

public long getLastCheckpointLockWaitDuration()

Gets the duration of last checkpoint lock wait in milliseconds.

Specified by:

getLastCheckpointLockWaitDuration in interface PersistenceMetricsMXBean

Specified by:

getLastCheckpointLockWaitDuration in interface PersistenceMetrics

Returns:

Checkpoint lock wait time in milliseconds.

getLastCheckpointMarkDuration

public long getLastCheckpointMarkDuration()

Gets the duration of last checkpoint mark phase in milliseconds.

Specified by:

getLastCheckpointMarkDuration in interface PersistenceMetricsMXBean

Specified by:

getLastCheckpointMarkDuration in interface PersistenceMetrics

Returns:

Checkpoint mark duration in milliseconds.

getLastCheckpointPagesWriteDuration

public long getLastCheckpointPagesWriteDuration()

Gets the duration of last checkpoint pages write phase in milliseconds.

Specified by:

getLastCheckpointPagesWriteDuration in interface PersistenceMetricsMXBean

Specified by:

getLastCheckpointPagesWriteDuration in interface PersistenceMetrics

Returns:

Checkpoint pages write phase in milliseconds.

getLastCheckpointFsyncDuration

public long getLastCheckpointFsyncDuration()

Gets the duration of the sync phase of the last checkpoint in milliseconds.

Specified by:

getLastCheckpointFsyncDuration in interface PersistenceMetricsMXBean

Specified by:

getLastCheckpointFsyncDuration in interface PersistenceMetrics

Returns:

Checkpoint fsync time in milliseconds.

getLastCheckpointTotalPagesNumber

public long getLastCheckpointTotalPagesNumber()

Gets the total number of pages written during the last checkpoint.

Specified by:

getLastCheckpointTotalPagesNumber in interface PersistenceMetricsMXBean

Specified by:

getLastCheckpointTotalPagesNumber in interface PersistenceMetrics

Returns:

Total number of pages written during the last checkpoint.

getLastCheckpointDataPagesNumber

public long getLastCheckpointDataPagesNumber()

Gets the number of data pages written during the last checkpoint.

Specified by:

getLastCheckpointDataPagesNumber in interface PersistenceMetricsMXBean

Specified by:

getLastCheckpointDataPagesNumber in interface PersistenceMetrics

Returns:

Total number of data pages written during the last checkpoint.

getLastCheckpointCopiedOnWritePagesNumber

public long getLastCheckpointCopiedOnWritePagesNumber()

Gets the number of pages copied to a temporary checkpoint buffer during the last checkpoint.

Specified by:

getLastCheckpointCopiedOnWritePagesNumber in interface PersistenceMetricsMXBean

Specified by:

getLastCheckpointCopiedOnWritePagesNumber in interface PersistenceMetrics

Returns:

Total number of pages copied to a temporary checkpoint buffer during the last checkpoint.

enableMetrics

public void enableMetrics()

Enables persistence metrics collection on an Apache Ignite node.

Specified by:

enableMetrics in interface PersistenceMetricsMXBean

disableMetrics

public void disableMetrics()

Disables persistence metrics collection on an Apache Ignite node.

Specified by:

disableMetrics in interface PersistenceMetricsMXBean

rateTimeInterval

public void rateTimeInterval(long rateTimeInterval)

Sets time interval for rate-based metrics. Identical to setting PersistentStoreConfiguration.setRateTimeInterval(long) configuration property.

Specified by:

rateTimeInterval in interface PersistenceMetricsMXBean

Parameters:

rateTimeInterval - Time interval (in milliseconds) used for allocation and eviction rates calculations.

subIntervals

public void subIntervals(int subInts)

Sets a number of sub-intervals the whole PersistenceMetricsMXBean.rateTimeInterval(long) will be split into to calculate rate-based metrics. Identical to setting PersistentStoreConfiguration.setSubIntervals(int) configuration property.

Specified by:

subIntervals in interface PersistenceMetricsMXBean

Parameters:

subInts - A number of sub-intervals.

wal

public void wal(IgniteWriteAheadLogManager wal)

Parameters:

wal - Write-ahead log manager.

metricsEnabled

public boolean metricsEnabled()

Returns:

Metrics enabled flag.

onCheckpoint

public void onCheckpoint(long lockWaitDuration,
                long markDuration,
                long pagesWriteDuration,
                long fsyncDuration,
                long duration,
                long totalPages,
                long dataPages,
                long cowPages)

Parameters:

lockWaitDuration - Lock wait duration.

markDuration - Mark duration.

pagesWriteDuration - Pages write duration.

fsyncDuration - Total checkpoint fsync duration.

duration - Total checkpoint duration.

totalPages - Total number of all pages in checkpoint.

dataPages - Total number of data pages in checkpoint.

cowPages - Total number of COW-ed pages in checkpoint.

onWalRecordLogged

public void onWalRecordLogged()

onWalBytesWritten

public void onWalBytesWritten(int size)

Parameters:

size - Size written.

onFsync

public void onFsync(long nanoTime)

Parameters:

nanoTime - Fsync nano time.