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%)