This is an automated email from the ASF dual-hosted git repository.
devesh 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 8747c0ea7a HDDS-11518. Recon OmDB Insights show isKey=true for
directories (#7260)
8747c0ea7a is described below
commit 8747c0ea7a8126cd9d18ba475eae84e2279b427c
Author: Arafat2198 <[email protected]>
AuthorDate: Thu Oct 3 12:22:20 2024 +0530
HDDS-11518. Recon OmDB Insights show isKey=true for directories (#7260)
---
.../java/org/apache/hadoop/ozone/recon/api/OMDBInsightEndpoint.java | 3 +++
.../org/apache/hadoop/ozone/recon/api/OMDBInsightSearchEndpoint.java | 1 +
.../java/org/apache/hadoop/ozone/recon/api/types/KeyEntityInfo.java | 4 ++--
3 files changed, 6 insertions(+), 2 deletions(-)
diff --git
a/hadoop-ozone/recon/src/main/java/org/apache/hadoop/ozone/recon/api/OMDBInsightEndpoint.java
b/hadoop-ozone/recon/src/main/java/org/apache/hadoop/ozone/recon/api/OMDBInsightEndpoint.java
index 4620b69fbe..5e278a21f3 100644
---
a/hadoop-ozone/recon/src/main/java/org/apache/hadoop/ozone/recon/api/OMDBInsightEndpoint.java
+++
b/hadoop-ozone/recon/src/main/java/org/apache/hadoop/ozone/recon/api/OMDBInsightEndpoint.java
@@ -235,6 +235,7 @@ public class OMDBInsightEndpoint {
continue;
}
KeyEntityInfo keyEntityInfo = new KeyEntityInfo();
+ keyEntityInfo.setIsKey(omKeyInfo.isFile());
keyEntityInfo.setKey(key);
keyEntityInfo.setPath(omKeyInfo.getKeyName());
keyEntityInfo.setInStateSince(omKeyInfo.getCreationTime());
@@ -549,6 +550,7 @@ public class OMDBInsightEndpoint {
continue;
}
KeyEntityInfo keyEntityInfo = new KeyEntityInfo();
+ keyEntityInfo.setIsKey(omKeyInfo.isFile());
keyEntityInfo.setKey(omKeyInfo.getFileName());
keyEntityInfo.setPath(createPath(omKeyInfo));
keyEntityInfo.setInStateSince(omKeyInfo.getCreationTime());
@@ -1257,6 +1259,7 @@ public class OMDBInsightEndpoint {
OmKeyInfo keyInfo)
throws IOException {
KeyEntityInfo keyEntityInfo = new KeyEntityInfo();
keyEntityInfo.setKey(dbKey); // Set the DB key
+ keyEntityInfo.setIsKey(keyInfo.isFile());
keyEntityInfo.setPath(ReconUtils.constructFullPath(keyInfo,
reconNamespaceSummaryManager,
omMetadataManager));
keyEntityInfo.setSize(keyInfo.getDataSize());
diff --git
a/hadoop-ozone/recon/src/main/java/org/apache/hadoop/ozone/recon/api/OMDBInsightSearchEndpoint.java
b/hadoop-ozone/recon/src/main/java/org/apache/hadoop/ozone/recon/api/OMDBInsightSearchEndpoint.java
index 58d2cd3107..16b5f20b12 100644
---
a/hadoop-ozone/recon/src/main/java/org/apache/hadoop/ozone/recon/api/OMDBInsightSearchEndpoint.java
+++
b/hadoop-ozone/recon/src/main/java/org/apache/hadoop/ozone/recon/api/OMDBInsightSearchEndpoint.java
@@ -380,6 +380,7 @@ public class OMDBInsightSearchEndpoint {
OmKeyInfo keyInfo) {
KeyEntityInfo keyEntityInfo = new KeyEntityInfo();
keyEntityInfo.setKey(dbKey); // Set the DB key
+ keyEntityInfo.setIsKey(keyInfo.isFile());
keyEntityInfo.setPath(keyInfo.getKeyName()); // Assuming path is the same
as key name
keyEntityInfo.setInStateSince(keyInfo.getCreationTime());
keyEntityInfo.setSize(keyInfo.getDataSize());
diff --git
a/hadoop-ozone/recon/src/main/java/org/apache/hadoop/ozone/recon/api/types/KeyEntityInfo.java
b/hadoop-ozone/recon/src/main/java/org/apache/hadoop/ozone/recon/api/types/KeyEntityInfo.java
index d7cd359919..8a56cbbd33 100644
---
a/hadoop-ozone/recon/src/main/java/org/apache/hadoop/ozone/recon/api/types/KeyEntityInfo.java
+++
b/hadoop-ozone/recon/src/main/java/org/apache/hadoop/ozone/recon/api/types/KeyEntityInfo.java
@@ -143,7 +143,7 @@ public class KeyEntityInfo {
return isKey;
}
- public void setKey(boolean key) {
- isKey = key;
+ public void setIsKey(boolean isKey) {
+ this.isKey = isKey;
}
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
