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 9c774d408 [INLONG-4314][License] Update Sort-standalone's third-party
dependency LICENSE (#4317)
add 4301bebef [INLONG-4236][Manager] Support create Elasticsearch indices
and mappings (#4238)
No new revisions were added by this update.
Summary of changes:
.../inlong/manager/common/enums/SinkType.java | 3 +-
.../manager/common/pojo/sink/SinkFieldBase.java | 3 +
.../es/ElasticsearchFieldInfo.java} | 44 ++++--
.../ElasticsearchSinkDTO.java} | 63 ++++----
.../ElasticsearchSinkListResponse.java} | 33 ++--
.../ElasticsearchSinkRequest.java} | 44 +++---
.../ElasticsearchSinkResponse.java} | 36 ++---
.../manager/dao/entity/StreamSinkFieldEntity.java | 1 +
.../mappers/StreamSinkFieldEntityMapper.xml | 10 +-
.../service/resource/ck/ClickHouseSqlBuilder.java | 1 -
.../service/resource/es/ElasticsearchApi.java | 171 ++++++++++++++++++++-
.../service/resource/es/ElasticsearchConfig.java | 9 +-
.../ElasticsearchResourceOperator.java} | 105 +++++++------
.../ElasticsearchSinkOperation.java} | 48 +++---
.../manager/service/sort/util/SinkInfoUtils.java | 22 +++
.../main/resources/sql/apache_inlong_manager.sql | 1 +
.../manager-web/sql/apache_inlong_manager.sql | 1 +
...useSinkInfo.java => ElasticsearchSinkInfo.java} | 91 +++--------
18 files changed, 421 insertions(+), 265 deletions(-)
copy
inlong-manager/manager-common/src/main/java/org/apache/inlong/manager/common/pojo/{source/autopush/AutoPushSourceDTO.java
=> sink/es/ElasticsearchFieldInfo.java} (59%)
copy
inlong-manager/manager-common/src/main/java/org/apache/inlong/manager/common/pojo/sink/{postgres/PostgresSinkDTO.java
=> es/ElasticsearchSinkDTO.java} (58%)
copy
inlong-manager/manager-common/src/main/java/org/apache/inlong/manager/common/pojo/sink/{ck/ClickHouseSinkListResponse.java
=> es/ElasticsearchSinkListResponse.java} (59%)
copy
inlong-manager/manager-common/src/main/java/org/apache/inlong/manager/common/pojo/sink/{ck/ClickHouseSinkListResponse.java
=> es/ElasticsearchSinkRequest.java} (58%)
copy
inlong-manager/manager-common/src/main/java/org/apache/inlong/manager/common/pojo/sink/{ck/ClickHouseSinkResponse.java
=> es/ElasticsearchSinkResponse.java} (64%)
copy
inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/resource/{hive/HiveResourceOperator.java
=> es/ElasticsearchResourceOperator.java} (50%)
copy
inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sink/{ck/ClickHouseSinkOperation.java
=> es/ElasticsearchSinkOperation.java} (83%)
copy
inlong-sort/sort-common/src/main/java/org/apache/inlong/sort/protocol/sink/{ClickHouseSinkInfo.java
=> ElasticsearchSinkInfo.java} (55%)
