You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@inlong.apache.org by he...@apache.org on 2022/01/18 05:03:47 UTC
[incubator-inlong] branch master updated (6745a98 -> c2439b5)
This is an automated email from the ASF dual-hosted git repository.
healchow pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-inlong.git.
from 6745a98 [INLONG-2174] Make the flush operation synchronized in clickhouse sink to prevent data loss (#2175)
add c2439b5 [INLONG-2051] audit query support mysql and elasticsearch (#2147)
No new revisions were added by this update.
Summary of changes:
.../{OperationType.java => AuditQuerySource.java} | 23 ++--
.../manager/common/enums/TimeStaticsDim.java} | 35 ++---
.../manager/common/pojo/audit/AuditRequest.java | 57 ++++++++
.../inlong/manager/common/pojo/audit/AuditVO.java} | 16 +--
.../inlong/manager/dao/entity/AuditEntity.java | 13 +-
...figEntityMapper.java => AuditEntityMapper.java} | 36 +++---
.../main/resources/mappers/AuditEntityMapper.xml | 54 ++++++++
inlong-manager/manager-service/pom.xml | 14 ++
.../{DataSchemaService.java => AuditService.java} | 20 +--
.../service/core/impl/AuditServiceImpl.java | 144 +++++++++++++++++++++
.../thirdpart/elasticsearch/ElasticsearchApi.java | 82 ++++++++++++
.../elasticsearch/ElasticsearchConfig.java | 104 +++++++++++++++
...sicInfoController.java => AuditController.java} | 40 ++----
.../src/main/resources/application-dev.properties | 21 ++-
.../src/main/resources/application-prod.properties | 21 ++-
.../src/main/resources/application-test.properties | 21 ++-
.../manager/service/core/AuditServiceTest.java | 69 ++++++++++
.../src/test/resources/application-test.properties | 22 ++--
inlong-manager/pom.xml | 23 ++++
19 files changed, 686 insertions(+), 129 deletions(-)
copy inlong-manager/manager-common/src/main/java/org/apache/inlong/manager/common/enums/{OperationType.java => AuditQuerySource.java} (84%)
copy inlong-manager/{manager-workflow-engine/src/main/java/org/apache/inlong/manager/workflow/model/ProcessState.java => manager-common/src/main/java/org/apache/inlong/manager/common/enums/TimeStaticsDim.java} (70%)
create mode 100644 inlong-manager/manager-common/src/main/java/org/apache/inlong/manager/common/pojo/audit/AuditRequest.java
copy inlong-manager/{manager-workflow-engine/src/main/java/org/apache/inlong/manager/workflow/model/view/PageQuery.java => manager-common/src/main/java/org/apache/inlong/manager/common/pojo/audit/AuditVO.java} (77%)
copy inlong-audit/audit-store/src/main/java/org/apache/inlong/store/db/entities/AuditDataPo.java => inlong-manager/manager-dao/src/main/java/org/apache/inlong/manager/dao/entity/AuditEntity.java (84%)
copy inlong-manager/manager-dao/src/main/java/org/apache/inlong/manager/dao/mapper/{DataSourceCmdConfigEntityMapper.java => AuditEntityMapper.java} (56%)
create mode 100644 inlong-manager/manager-dao/src/main/resources/mappers/AuditEntityMapper.xml
copy inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/core/{DataSchemaService.java => AuditService.java} (69%)
create mode 100644 inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/core/impl/AuditServiceImpl.java
create mode 100644 inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/thirdpart/elasticsearch/ElasticsearchApi.java
create mode 100644 inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/thirdpart/elasticsearch/ElasticsearchConfig.java
copy inlong-manager/manager-web/src/main/java/org/apache/inlong/manager/web/controller/{BasicInfoController.java => AuditController.java} (52%)
create mode 100644 inlong-manager/manager-web/src/test/java/org/apache/inlong/manager/service/core/AuditServiceTest.java