This is an automated email from the ASF dual-hosted git repository.
zirui pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/inlong.git
from c7226e0fa [INLONG-7772][Dashboard] Redis sentinel master name
normalization in NodeManagement (#7773)
add bdeb20d2d [INLONG-7581][Sort] Support multiple-sink migration for
Elasticsearch (#7712)
No new revisions were added by this update.
Summary of changes:
.../manager/pojo/sink/es/ElasticsearchSink.java | 9 ++
.../manager/pojo/sort/util/LoadNodeUtils.java | 22 +++-
.../protocol/node/load/ElasticsearchLoadNode.java | 22 +++-
.../protocol/node/load/ElasticSearchNodeTest.java | 2 +-
...a => MultipleRowElasticsearchSinkFunction.java} | 25 +++--
.../table/Elasticsearch6DynamicSink.java | 74 ++++++++++---
.../table/Elasticsearch6DynamicSinkFactory.java | 19 +++-
...a => MultipleRowElasticsearchSinkFunction.java} | 25 +++--
.../table/Elasticsearch7Configuration.java | 1 +
.../table/Elasticsearch7DynamicSink.java | 77 ++++++++++---
.../table/Elasticsearch7DynamicSinkFactory.java | 22 +++-
.../sort-connectors/elasticsearch-base/pom.xml | 12 ++-
.../table/ElasticsearchConfiguration.java | 4 +
.../elasticsearch/table/ElasticsearchOptions.java | 8 ++
... => MultipleElasticsearchSinkFunctionBase.java} | 120 ++++++++++++++++-----
...IndexGenerator.java => TableSchemaFactory.java} | 25 ++---
...ltipleSinkTest.java => ESMultipleSinkTest.java} | 22 ++--
.../sort/parser/ElasticsearchSqlParseTest.java | 17 +--
18 files changed, 391 insertions(+), 115 deletions(-)
copy
inlong-sort/sort-connectors/elasticsearch-6/src/main/java/org/apache/inlong/sort/elasticsearch6/{RowElasticsearchSinkFunction.java
=> MultipleRowElasticsearchSinkFunction.java} (70%)
copy
inlong-sort/sort-connectors/elasticsearch-7/src/main/java/org/apache/inlong/sort/elasticsearch7/{RowElasticsearchSinkFunction.java
=> MultipleRowElasticsearchSinkFunction.java} (70%)
copy
inlong-sort/sort-connectors/elasticsearch-base/src/main/java/org/apache/inlong/sort/elasticsearch/table/{ElasticsearchSinkFunctionBase.java
=> MultipleElasticsearchSinkFunctionBase.java} (61%)
copy
inlong-sort/sort-connectors/elasticsearch-base/src/main/java/org/apache/inlong/sort/elasticsearch/table/{IndexGenerator.java
=> TableSchemaFactory.java} (62%)
copy
inlong-sort/sort-core/src/test/java/org/apache/inlong/sort/parser/{DorisMultipleSinkTest.java
=> ESMultipleSinkTest.java} (88%)
