This is an automated email from the ASF dual-hosted git repository.
ritesh pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/ozone.git
The following commit(s) were added to refs/heads/master by this push:
new a21a73d608 HDDS-9096. Add OM performance metrics for listKeys
operation (#5131)
a21a73d608 is described below
commit a21a73d608539da5c99325cb8d2c39284736a7c6
Author: tanvipenumudy <[email protected]>
AuthorDate: Mon Aug 21 11:13:28 2023 +0530
HDDS-9096. Add OM performance metrics for listKeys operation (#5131)
---
.../main/java/org/apache/hadoop/ozone/om/OMPerformanceMetrics.java | 7 +++++++
.../src/main/java/org/apache/hadoop/ozone/om/OmMetadataReader.java | 3 ++-
2 files changed, 9 insertions(+), 1 deletion(-)
diff --git
a/hadoop-ozone/ozone-manager/src/main/java/org/apache/hadoop/ozone/om/OMPerformanceMetrics.java
b/hadoop-ozone/ozone-manager/src/main/java/org/apache/hadoop/ozone/om/OMPerformanceMetrics.java
index a511549dee..d18000e167 100644
---
a/hadoop-ozone/ozone-manager/src/main/java/org/apache/hadoop/ozone/om/OMPerformanceMetrics.java
+++
b/hadoop-ozone/ozone-manager/src/main/java/org/apache/hadoop/ozone/om/OMPerformanceMetrics.java
@@ -86,6 +86,9 @@ public class OMPerformanceMetrics {
@Metric(about = "checkAccess latency in nanoseconds")
private MutableRate checkAccessLatencyNs;
+ @Metric(about = "listKeys latency in nanoseconds")
+ private MutableRate listKeysLatencyNs;
+
public void addLookupLatency(long latencyInNs) {
lookupLatencyNs.add(latencyInNs);
}
@@ -146,4 +149,8 @@ public class OMPerformanceMetrics {
public void setCheckAccessLatencyNs(long latencyInNs) {
checkAccessLatencyNs.add(latencyInNs);
}
+
+ public void addListKeysLatencyNs(long latencyInNs) {
+ listKeysLatencyNs.add(latencyInNs);
+ }
}
diff --git
a/hadoop-ozone/ozone-manager/src/main/java/org/apache/hadoop/ozone/om/OmMetadataReader.java
b/hadoop-ozone/ozone-manager/src/main/java/org/apache/hadoop/ozone/om/OmMetadataReader.java
index af671cb5d7..72506d9821 100644
---
a/hadoop-ozone/ozone-manager/src/main/java/org/apache/hadoop/ozone/om/OmMetadataReader.java
+++
b/hadoop-ozone/ozone-manager/src/main/java/org/apache/hadoop/ozone/om/OmMetadataReader.java
@@ -307,7 +307,7 @@ public class OmMetadataReader implements IOmMetadataReader,
Auditor {
@Override
public List<OmKeyInfo> listKeys(String volumeName, String bucketName,
String startKey, String keyPrefix, int maxKeys) throws IOException {
-
+ long startNanos = Time.monotonicNowNanos();
ResolvedBucket bucket = ozoneManager.resolveBucketLink(
Pair.of(volumeName, bucketName));
@@ -336,6 +336,7 @@ public class OmMetadataReader implements IOmMetadataReader,
Auditor {
audit.logReadSuccess(buildAuditMessageForSuccess(OMAction.LIST_KEYS,
auditMap));
}
+ perfMetrics.addListKeysLatencyNs(Time.monotonicNowNanos() - startNanos);
}
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
