This is an automated email from the ASF dual-hosted git repository.
kirs pushed a change to branch dev
in repository https://gitbox.apache.org/repos/asf/seatunnel.git
from 87db4d1f8b [Feature][Zeta] add new job status `DOING_SAVEPOINT` and
`SAVEPOINT_DONE` (#5917)
add 1d3e335d8e [Feature][Catalog] Doris Catalog (#5175)
No new revisions were added by this update.
Summary of changes:
.../connectors/doris/catalog/DorisCatalog.java | 332 +++++++++++++++++++++
.../doris/catalog/DorisCatalogFactory.java} | 22 +-
.../connectors/doris/config/DorisConfig.java | 329 +++++---------------
.../connectors/doris/config/DorisOptions.java | 231 ++++++++++++++
.../connectors/doris/config/DorisSinkFactory.java | 12 +-
.../connectors/doris/rest/RestService.java | 19 +-
.../seatunnel/connectors/doris/sink/DorisSink.java | 52 +++-
.../connectors/doris/sink/DorisSinkFactory.java} | 29 +-
.../doris/sink/committer/DorisCommitter.java | 14 +-
.../doris/sink/writer/DorisSinkWriter.java | 6 +-
.../connectors/doris}/util/CreateTableParser.java | 2 +-
.../connectors/doris/util/DorisCatalogUtil.java | 274 +++++++++++++++++
.../connector-doris-e2e/pom.xml | 10 +
.../e2e/connector/doris/DorisCatalogIT.java | 244 +++++++++++++++
.../resources/write-cdc-changelog-to-doris.conf | 48 +--
15 files changed, 1271 insertions(+), 353 deletions(-)
create mode 100644
seatunnel-connectors-v2/connector-doris/src/main/java/org/apache/seatunnel/connectors/doris/catalog/DorisCatalog.java
copy
seatunnel-connectors-v2/{connector-elasticsearch/src/main/java/org/apache/seatunnel/connectors/seatunnel/elasticsearch/catalog/ElasticSearchCatalogFactory.java
=>
connector-doris/src/main/java/org/apache/seatunnel/connectors/doris/catalog/DorisCatalogFactory.java}
(64%)
create mode 100644
seatunnel-connectors-v2/connector-doris/src/main/java/org/apache/seatunnel/connectors/doris/config/DorisOptions.java
copy
seatunnel-connectors-v2/{connector-amazonsqs/src/main/java/org/apache/seatunnel/connectors/seatunnel/amazonsqs/sink/AmazonSqsSinkFactory.java
=>
connector-doris/src/main/java/org/apache/seatunnel/connectors/doris/sink/DorisSinkFactory.java}
(67%)
copy
seatunnel-connectors-v2/{connector-starrocks/src/main/java/org/apache/seatunnel/connectors/seatunnel/starrocks
=>
connector-doris/src/main/java/org/apache/seatunnel/connectors/doris}/util/CreateTableParser.java
(98%)
create mode 100644
seatunnel-connectors-v2/connector-doris/src/main/java/org/apache/seatunnel/connectors/doris/util/DorisCatalogUtil.java
create mode 100644
seatunnel-e2e/seatunnel-connector-v2-e2e/connector-doris-e2e/src/test/java/org/apache/seatunnel/e2e/connector/doris/DorisCatalogIT.java
