(ranger) branch ranger-2.10 updated: RANGER-5867: update audit retrieval to handle opensearch (#1351)

[madhan.apache.org via commits]

This is an automated email from the ASF dual-hosted git repository.

mneethiraj pushed a commit to branch ranger-2.10
in repository https://gitbox.apache.org/repos/asf/ranger.git


The following commit(s) were added to refs/heads/ranger-2.10 by this push:
     new 02656547d RANGER-5867: update audit retrieval to handle opensearch 
(#1351)
02656547d is described below

commit 02656547d667393977d1055b920b0f2b5144b44e
Author: Madhan Neethiraj <mad...@apache.org>
AuthorDate: Mon Nov 2 10:00:42 2026 -0800

    RANGER-5867: update audit retrieval to handle opensearch (#1351)
---
 security-admin/src/main/java/org/apache/ranger/biz/AssetMgr.java | 6 ++++++
 1 file changed, 6 insertions(+)

diff --git a/security-admin/src/main/java/org/apache/ranger/biz/AssetMgr.java 
b/security-admin/src/main/java/org/apache/ranger/biz/AssetMgr.java
index d80e296c1..9c013fc90 100644
--- a/security-admin/src/main/java/org/apache/ranger/biz/AssetMgr.java
+++ b/security-admin/src/main/java/org/apache/ranger/biz/AssetMgr.java
@@ -55,6 +55,7 @@
 import org.apache.ranger.entity.XXPolicyExportAudit;
 import org.apache.ranger.entity.XXPortalUser;
 import org.apache.ranger.entity.XXUser;
+import org.apache.ranger.opensearch.OpenSearchAccessAuditsService;
 import org.apache.ranger.plugin.model.RangerPluginInfo;
 import org.apache.ranger.plugin.store.PList;
 import org.apache.ranger.plugin.util.RangerPluginCapability;
@@ -120,6 +121,9 @@ public class AssetMgr extends AssetMgrBase {
        @Autowired
        ElasticSearchAccessAuditsService elasticSearchAccessAuditsService;
 
+       @Autowired
+       OpenSearchAccessAuditsService openSearchAccessAuditsService;
+
        @Autowired
        CloudWatchAccessAuditsService cloudWatchAccessAuditsService;
 
@@ -1171,6 +1175,8 @@ public VXAccessAuditList getAccessLogs(SearchCriteria 
searchCriteria) {
             return solrAccessAuditsService.searchXAccessAudits(searchCriteria);
         } else if 
(RangerBizUtil.AUDIT_STORE_ELASTIC_SEARCH.equalsIgnoreCase(xaBizUtil.getAuditDBType()))
 {
             return 
elasticSearchAccessAuditsService.searchXAccessAudits(searchCriteria);
+        } else if 
(RangerBizUtil.AUDIT_STORE_OPENSEARCH.equalsIgnoreCase(xaBizUtil.getAuditDBType()))
 {
+            return 
openSearchAccessAuditsService.searchXAccessAudits(searchCriteria);
         } else if 
(RangerBizUtil.AUDIT_STORE_CLOUD_WATCH.equalsIgnoreCase(xaBizUtil.getAuditDBType()))
 {
             return 
cloudWatchAccessAuditsService.searchXAccessAudits(searchCriteria);
         } else {