You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@inlong.apache.org by do...@apache.org on 2022/01/20 12:14:07 UTC

[incubator-inlong] branch master updated (f1152c9 -> 8502704)

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

dockerzhang pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-inlong.git.


    from f1152c9  [INLONG-2242][manager] table field incorrect: db_collector_detail_task, 'sql' should be 'sql_statement' (#2243)
     add 8502704  [INLONG-2050] Audit Store for Elasticsearch (#2178)

No new revisions were added by this update.

Summary of changes:
 .../audit-store/conf/application.properties        |  19 +-
 inlong-audit/audit-store/pom.xml                   |  87 ++++++
 .../java/org/apache/inlong/store/Application.java  |   3 +-
 .../inlong/store/config/ElasticsearchConfig.java   | 109 +++++++
 .../apache/inlong/store/config/StoreConfig.java    |  23 +-
 .../inlong/store/db/entities/AuditDataPo.java      |   3 +-
 .../entities/{AuditDataPo.java => ESDataPo.java}   |  15 +-
 .../store/service/AuditMsgConsumerServer.java      |  80 +++--
 .../inlong/store/service/ElasticsearchService.java | 322 +++++++++++++++++++++
 .../store/service/ElasticsearchServiceTest.java    | 110 +++++++
 .../test/resources}/application.properties         |  21 +-
 .../resources/mapper/AuditDataDao.xml              |   0
 inlong-audit/pom.xml                               |  51 +++-
 13 files changed, 798 insertions(+), 45 deletions(-)
 create mode 100644 inlong-audit/audit-store/src/main/java/org/apache/inlong/store/config/ElasticsearchConfig.java
 copy inlong-manager/manager-common/src/main/java/org/apache/inlong/manager/common/conversion/HoursToMinute.java => inlong-audit/audit-store/src/main/java/org/apache/inlong/store/config/StoreConfig.java (66%)
 copy inlong-audit/audit-store/src/main/java/org/apache/inlong/store/db/entities/{AuditDataPo.java => ESDataPo.java} (82%)
 create mode 100644 inlong-audit/audit-store/src/main/java/org/apache/inlong/store/service/ElasticsearchService.java
 create mode 100644 inlong-audit/audit-store/src/test/java/org/apache/inlong/store/service/ElasticsearchServiceTest.java
 copy inlong-audit/audit-store/{conf => src/test/resources}/application.properties (80%)
 copy inlong-audit/audit-store/src/{main => test}/resources/mapper/AuditDataDao.xml (100%)