Package org.apache.hadoop.ozone.om

Class DeletingServiceMetrics

java.lang.Object

org.apache.hadoop.ozone.om.DeletingServiceMetrics

@Metrics(about="Deletion Service Metrics",
         context="ozone")
public final class DeletingServiceMetrics
extends Object

Class contains metrics related to the OM Deletion services.

Field Summary

Fields

Modifier and Type	Field	Description
static final String	METRICS_SOURCE_NAME

Method Summary

Modifier and Type	Method	Description
static DeletingServiceMetrics	create()	Creates and returns DeletingServiceMetrics instance.
long	getAosKeysIteratedLast()
long	getAosKeysNotReclaimableLast()
long	getAosKeysReclaimedLast()
long	getAosReclaimedSizeLast()
long	getKeysReclaimedInInterval()
org.apache.hadoop.hdds.utils.TransactionInfo	getLastAOSTransactionInfo()
long	getNumDirsPurged()
long	getNumDirsSentForPurge()
long	getNumSubDirsMovedToDeletedDirTable()
long	getNumSubDirsSentForPurge()
long	getNumSubFilesMovedToDeletedTable()
long	getNumSubFilesSentForPurge()
long	getReclaimedSizeInInterval()
long	getSnapKeysIteratedLast()
long	getSnapKeysNotReclaimableLast()
long	getSnapKeysReclaimedLast()
long	getSnapReclaimedSizeLast()
void	incrementDirectoryDeletionTotalMetrics(long dirDel, long dirMove, long filesMove)
void	incrNumDirPurged(long dirPurged)
void	incrNumDirsSentForPurge(long dirDel)
void	incrNumKeysProcessed(long keysProcessed)
void	incrNumKeysPurged(long keysPurged)
void	incrNumKeysSentForPurge(long keysPurge)
void	incrNumRenameEntriesPurged(long renameEntriesPurged)
void	incrNumSubDirectoriesMoved(long subDirectories)
void	incrNumSubDirsSentForPurge(long delta)
void	incrNumSubFilesMoved(long subKeys)
void	incrNumSubFilesSentForPurge(long delta)
void	resetDirectoryMetrics()
void	setKdsCurRunTimestamp(long timestamp)
void	setKdsLastRunTimestamp(long timestamp)
void	setLastAOSTransactionInfo(org.apache.hadoop.hdds.utils.TransactionInfo transactionInfo)
static void	unregister()	Unregister the metrics instance.
void	updateAosLastRunMetrics(long keysReclaimed, long replicatedSizeBytes, long iteratedKeys, long notReclaimableKeys)
void	updateIntervalCumulativeMetrics(long keysReclaimed, long replicatedSizeBytes)
void	updateSnapLastRunMetrics(long keysReclaimed, long replicatedSizeBytes, long iteratedKeys, long notReclaimableKeys)

Methods inherited from class java.lang.Object

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

Field Details

METRICS_SOURCE_NAME

public static final String METRICS_SOURCE_NAME

Method Details

create

public static DeletingServiceMetrics create()

Creates and returns DeletingServiceMetrics instance.

Returns:

DeletingServiceMetrics

unregister

public static void unregister()

Unregister the metrics instance.

incrNumDirsSentForPurge

public void incrNumDirsSentForPurge(long dirDel)

incrNumSubDirsSentForPurge

public void incrNumSubDirsSentForPurge(long delta)

incrNumSubFilesSentForPurge

public void incrNumSubFilesSentForPurge(long delta)

incrementDirectoryDeletionTotalMetrics

public void incrementDirectoryDeletionTotalMetrics(long dirDel,
 long dirMove,
 long filesMove)

getNumDirsSentForPurge

public long getNumDirsSentForPurge()

getNumSubDirsSentForPurge

public long getNumSubDirsSentForPurge()

getNumSubFilesSentForPurge

public long getNumSubFilesSentForPurge()

incrNumKeysProcessed

public void incrNumKeysProcessed(long keysProcessed)

incrNumKeysSentForPurge

public void incrNumKeysSentForPurge(long keysPurge)

incrNumDirPurged

public void incrNumDirPurged(long dirPurged)

incrNumSubFilesMoved

public void incrNumSubFilesMoved(long subKeys)

incrNumSubDirectoriesMoved

public void incrNumSubDirectoriesMoved(long subDirectories)

getNumDirsPurged

public long getNumDirsPurged()

getNumSubFilesMovedToDeletedTable

public long getNumSubFilesMovedToDeletedTable()

getNumSubDirsMovedToDeletedDirTable

public long getNumSubDirsMovedToDeletedDirTable()

incrNumKeysPurged

public void incrNumKeysPurged(long keysPurged)

incrNumRenameEntriesPurged

public void incrNumRenameEntriesPurged(long renameEntriesPurged)

setKdsLastRunTimestamp

public void setKdsLastRunTimestamp(long timestamp)

setKdsCurRunTimestamp

public void setKdsCurRunTimestamp(long timestamp)

updateIntervalCumulativeMetrics

public void updateIntervalCumulativeMetrics(long keysReclaimed,
 long replicatedSizeBytes)

getKeysReclaimedInInterval

public long getKeysReclaimedInInterval()

getReclaimedSizeInInterval

public long getReclaimedSizeInInterval()

updateAosLastRunMetrics

public void updateAosLastRunMetrics(long keysReclaimed,
 long replicatedSizeBytes,
 long iteratedKeys,
 long notReclaimableKeys)

getAosKeysReclaimedLast

public long getAosKeysReclaimedLast()

getAosReclaimedSizeLast

public long getAosReclaimedSizeLast()

getAosKeysIteratedLast

public long getAosKeysIteratedLast()

getAosKeysNotReclaimableLast

public long getAosKeysNotReclaimableLast()

updateSnapLastRunMetrics

public void updateSnapLastRunMetrics(long keysReclaimed,
 long replicatedSizeBytes,
 long iteratedKeys,
 long notReclaimableKeys)

getSnapKeysReclaimedLast

public long getSnapKeysReclaimedLast()

getSnapReclaimedSizeLast

public long getSnapReclaimedSizeLast()

getSnapKeysIteratedLast

public long getSnapKeysIteratedLast()

getSnapKeysNotReclaimableLast

public long getSnapKeysNotReclaimableLast()

getLastAOSTransactionInfo

public org.apache.hadoop.hdds.utils.TransactionInfo getLastAOSTransactionInfo()

setLastAOSTransactionInfo

public void setLastAOSTransactionInfo(org.apache.hadoop.hdds.utils.TransactionInfo transactionInfo)

resetDirectoryMetrics

public void resetDirectoryMetrics()