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