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

Class DataStorageMetricsImpl

java.lang.Object

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

public class DataStorageMetricsImpl
extends Object

Field Summary

Fields

Modifier and Type	Field and Description
static String	DATASTORAGE_METRIC_PREFIX Prefix for all data storage metrics.

Constructor Summary

Constructors

Constructor and Description
DataStorageMetricsImpl(GridMetricManager mmgr, boolean metricsEnabled, long rateTimeInterval, int subInts)

Method Summary

Modifier and Type	Method and Description
boolean	metricsEnabled() Deprecated. Will be removed in upcoming releases.
void	onBuffPollSpin(int num)
void	onCheckpoint(long beforeLockDuration, long lockWaitDuration, long listenersExecuteDuration, long markDuration, long lockHoldDuration, long pagesWriteDuration, long fsyncDuration, long walRecordFsyncDuration, long writeEntryDuration, long splitAndSortPagesDuration, long duration, long start, long totalPages, long dataPages, long cowPages, long storageSize, long sparseStorageSize)
void	onFsync(long nanoTime)
void	onWallRollOver()
void	onWalRecordLogged(long size) Callback on logging a record to a WAL.
void	onWalSegmentCompressed(long size) Callback on compression of a WAL segment.
void	regionMetrics(Collection<DataRegionMetrics> regionMetrics)
void	setWalSizeProvider(IgniteOutClosure<Long> walSizeProvider)
void	wal(IgniteWriteAheadLogManager wal)

Methods inherited from class java.lang.Object

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

Field Detail

DATASTORAGE_METRIC_PREFIX

public static final String DATASTORAGE_METRIC_PREFIX

Prefix for all data storage metrics.

See Also:

Constant Field Values

Constructor Detail

DataStorageMetricsImpl

public DataStorageMetricsImpl(GridMetricManager mmgr,
                              boolean metricsEnabled,
                              long rateTimeInterval,
                              int subInts)

Parameters:

mmgr - Metrics manager.

metricsEnabled - Metrics enabled flag.

rateTimeInterval - Rate time interval.

subInts - Number of sub-intervals.

Method Detail

wal

public void wal(IgniteWriteAheadLogManager wal)

Parameters:

wal - Write-ahead log manager.

setWalSizeProvider

public void setWalSizeProvider(IgniteOutClosure<Long> walSizeProvider)

Parameters:

walSizeProvider - Wal size provider.

onWallRollOver

public void onWallRollOver()

regionMetrics

public void regionMetrics(Collection<DataRegionMetrics> regionMetrics)

metricsEnabled

@Deprecated
public boolean metricsEnabled()

Deprecated. Will be removed in upcoming releases.

Returns:

Metrics enabled flag.

onCheckpoint

public void onCheckpoint(long beforeLockDuration,
                         long lockWaitDuration,
                         long listenersExecuteDuration,
                         long markDuration,
                         long lockHoldDuration,
                         long pagesWriteDuration,
                         long fsyncDuration,
                         long walRecordFsyncDuration,
                         long writeEntryDuration,
                         long splitAndSortPagesDuration,
                         long duration,
                         long start,
                         long totalPages,
                         long dataPages,
                         long cowPages,
                         long storageSize,
                         long sparseStorageSize)

Parameters:

beforeLockDuration - Checkpoint action before taken write lock duration.

lockWaitDuration - Lock wait duration.

listenersExecuteDuration - Execution listeners under write lock duration.

markDuration - Mark duration.

lockHoldDuration - Lock hold duration.

pagesWriteDuration - Pages write duration.

fsyncDuration - Total checkpoint fsync duration.

walRecordFsyncDuration - Duration of WAL fsync after logging CheckpointRecord on checkpoint begin.

writeEntryDuration - Duration of checkpoint entry buffer writing to file.

splitAndSortPagesDuration - Duration of splitting and sorting checkpoint pages.

duration - Total checkpoint duration.

start - Checkpoint start time.

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.

storageSize - Storage space allocated, in bytes.

sparseStorageSize - Storage space allocated adjusted for possible sparsity, in bytes.

onWalRecordLogged

public void onWalRecordLogged(long size)

Callback on logging a record to a WAL.

Parameters:

size - Record size in bytes.

onFsync

public void onFsync(long nanoTime)

Parameters:

nanoTime - Fsync nano time.

onBuffPollSpin

public void onBuffPollSpin(int num)

Parameters:

num - Number.

onWalSegmentCompressed

public void onWalSegmentCompressed(long size)

Callback on compression of a WAL segment.

Parameters:

size - Size of the compressed segment in bytes.