(inlong) branch master updated: Add HDFS Audit items in the Audit SDK (#10380)

[doleyzi]

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

doleyzi pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/inlong.git


The following commit(s) were added to refs/heads/master by this push:
     new 6b4e028278 Add HDFS Audit items in the Audit SDK (#10380)
6b4e028278 is described below

commit 6b4e028278cedba497da264349d9c6b3d6a64101
Author: doleyzi <43397300+dole...@users.noreply.github.com>
AuthorDate: Tue Jun 11 11:19:11 2024 +0800

    Add HDFS Audit items in the Audit SDK (#10380)
---
 .../src/main/java/org/apache/inlong/audit/AuditIdEnum.java          | 6 +++++-
 .../src/main/java/org/apache/inlong/audit/entity/AuditType.java     | 3 ++-
 .../main/java/org/apache/inlong/audit/util/AuditManagerUtils.java   | 5 +++++
 3 files changed, 12 insertions(+), 2 deletions(-)

diff --git 
a/inlong-audit/audit-sdk/src/main/java/org/apache/inlong/audit/AuditIdEnum.java 
b/inlong-audit/audit-sdk/src/main/java/org/apache/inlong/audit/AuditIdEnum.java
index d63bc3a17a..ca437fb035 100644
--- 
a/inlong-audit/audit-sdk/src/main/java/org/apache/inlong/audit/AuditIdEnum.java
+++ 
b/inlong-audit/audit-sdk/src/main/java/org/apache/inlong/audit/AuditIdEnum.java
@@ -31,6 +31,7 @@ import static 
org.apache.inlong.audit.entity.AuditType.DATAPROXY;
 import static org.apache.inlong.audit.entity.AuditType.DORIS;
 import static org.apache.inlong.audit.entity.AuditType.ELASTICSEARCH;
 import static org.apache.inlong.audit.entity.AuditType.HBASE;
+import static org.apache.inlong.audit.entity.AuditType.HDFS;
 import static org.apache.inlong.audit.entity.AuditType.HIVE;
 import static org.apache.inlong.audit.entity.AuditType.HUDI;
 import static org.apache.inlong.audit.entity.AuditType.ICEBERG;
@@ -94,7 +95,10 @@ public enum AuditIdEnum {
     SORT_TUBE_OUTPUT(34, OUTPUT, TUBE, "Sent Audit Metrics for Sort Tube"),
 
     SORT_MYSQL_INPUT(35, INPUT, MYSQL, "Received Audit Metrics for Sort 
MySQL"),
-    SORT_MYSQL_OUTPUT(36, OUTPUT, MYSQL, "Sent Audit Metrics for Sort MySQL");
+    SORT_MYSQL_OUTPUT(36, OUTPUT, MYSQL, "Sent Audit Metrics for Sort MySQL"),
+
+    SORT_HDFS_INPUT(37, INPUT, HDFS, "Received Audit Metrics for Sort HDFS"),
+    SORT_HDFS_OUTPUT(38, OUTPUT, HDFS, "Sent Audit Metrics for Sort HDFS");
 
     private static final Logger LOGGER = 
LoggerFactory.getLogger(AuditIdEnum.class);
     private final int auditId;
diff --git 
a/inlong-audit/audit-sdk/src/main/java/org/apache/inlong/audit/entity/AuditType.java
 
b/inlong-audit/audit-sdk/src/main/java/org/apache/inlong/audit/entity/AuditType.java
index 6fb554b407..0af03844d6 100644
--- 
a/inlong-audit/audit-sdk/src/main/java/org/apache/inlong/audit/entity/AuditType.java
+++ 
b/inlong-audit/audit-sdk/src/main/java/org/apache/inlong/audit/entity/AuditType.java
@@ -34,7 +34,8 @@ public enum AuditType {
     POSTGRES("Postgres"),
     BINLOG("Binlog"),
     TUBE("Tube"),
-    MYSQL("MySQL");
+    MYSQL("MySQL"),
+    HDFS("HDFS");
 
     private final String auditType;
 
diff --git 
a/inlong-audit/audit-sdk/src/main/java/org/apache/inlong/audit/util/AuditManagerUtils.java
 
b/inlong-audit/audit-sdk/src/main/java/org/apache/inlong/audit/util/AuditManagerUtils.java
index 8bc2c8e7a3..35009d22df 100644
--- 
a/inlong-audit/audit-sdk/src/main/java/org/apache/inlong/audit/util/AuditManagerUtils.java
+++ 
b/inlong-audit/audit-sdk/src/main/java/org/apache/inlong/audit/util/AuditManagerUtils.java
@@ -18,6 +18,7 @@
 package org.apache.inlong.audit.util;
 
 import org.apache.inlong.audit.AuditIdEnum;
+import org.apache.inlong.audit.MetricIdEnum;
 import org.apache.inlong.audit.entity.AuditInformation;
 import org.apache.inlong.audit.entity.FlowType;
 
@@ -135,6 +136,10 @@ public class AuditManagerUtils {
             
auditInformationList.addAll(combineAuditInformation(auditIdEnum.getAuditType().value(),
                     auditIdEnum.getFlowType()));
         }
+        for (MetricIdEnum metricIdEnum : MetricIdEnum.values()) {
+            auditInformationList.add(new 
AuditInformation(metricIdEnum.getValue(), metricIdEnum.getEnglishDescription(),
+                    metricIdEnum.getChineseDescription()));
+        }
         return auditInformationList;
     }