This is an automated email from the ASF dual-hosted git repository.
github-merge-queue[bot] pushed a change to branch dev
in repository https://gitbox.apache.org/repos/asf/seatunnel.git
from d3f89cd31c [Fix][Zeta] Propagate interrupted pending job insertion
(#12052)
add c57dfaa8d0 [Feature][Connector-V2] Add Amazon DocumentDB source
connector (#12046)
No new revisions were added by this update.
Summary of changes:
.github/workflows/labeler/label-scope-conf.yml | 5 +
config/plugin_config | 1 +
.../changelog/connector-amazondocumentdb.md | 24 ++
docs/en/connectors/source/AmazonDocumentDB.md | 231 +++++++++++++++++
.../changelog/connector-amazondocumentdb.md | 24 ++
docs/zh/connectors/source/AmazonDocumentDB.md | 231 +++++++++++++++++
plugin-mapping.properties | 1 +
.../pom.xml | 14 +-
.../config/AmazonDocumentDBConfig.java | 275 +++++++++++++++++++++
.../config/AmazonDocumentDBSourceOptions.java | 77 ++++++
.../serialize/DocumentDBItemDeserializer.java | 240 ++++++++++++++++++
.../source/AmazonDocumentDBSource.java | 90 +++++++
.../source/AmazonDocumentDBSourceFactory.java} | 37 +--
.../source/AmazonDocumentDBSourceReader.java | 221 +++++++++++++++++
.../source/AmazonDocumentDBSourceSplit.java} | 36 +--
.../AmazonDocumentDBSourceSplitEnumerator.java | 200 +++++++++++++++
.../source/AmazonDocumentDBSourceState.java | 66 +++++
.../AmazonDocumentDBSourceFactoryTest.java | 55 +++++
.../DocumentDBItemDeserializerTest.java | 181 ++++++++++++++
.../config/AmazonDocumentDBConfigTest.java | 134 ++++++++++
.../source/AmazonDocumentDBSourceReaderTest.java} | 153 +++++++++---
.../AmazonDocumentDBSourceSplitEnumeratorTest.java | 189 ++++++++++++++
seatunnel-connectors-v2/pom.xml | 1 +
seatunnel-dist/pom.xml | 6 +
.../pom.xml | 18 +-
.../amazondocumentdb/AmazonDocumentDBIT.java | 155 ++++++++++++
.../resources/amazondocumentdb_source_basic.conf} | 20 +-
.../amazondocumentdb_source_projection.conf} | 27 +-
.../amazondocumentdb_source_query_filter.conf} | 28 +--
seatunnel-e2e/seatunnel-connector-v2-e2e/pom.xml | 1 +
30 files changed, 2598 insertions(+), 143 deletions(-)
create mode 100644 docs/en/connectors/changelog/connector-amazondocumentdb.md
create mode 100644 docs/en/connectors/source/AmazonDocumentDB.md
create mode 100644 docs/zh/connectors/changelog/connector-amazondocumentdb.md
create mode 100644 docs/zh/connectors/source/AmazonDocumentDB.md
copy seatunnel-connectors-v2/{connector-mongodb =>
connector-amazondocumentdb}/pom.xml (88%)
create mode 100644
seatunnel-connectors-v2/connector-amazondocumentdb/src/main/java/org/apache/seatunnel/connectors/seatunnel/amazondocumentdb/config/AmazonDocumentDBConfig.java
create mode 100644
seatunnel-connectors-v2/connector-amazondocumentdb/src/main/java/org/apache/seatunnel/connectors/seatunnel/amazondocumentdb/config/AmazonDocumentDBSourceOptions.java
create mode 100644
seatunnel-connectors-v2/connector-amazondocumentdb/src/main/java/org/apache/seatunnel/connectors/seatunnel/amazondocumentdb/serialize/DocumentDBItemDeserializer.java
create mode 100644
seatunnel-connectors-v2/connector-amazondocumentdb/src/main/java/org/apache/seatunnel/connectors/seatunnel/amazondocumentdb/source/AmazonDocumentDBSource.java
copy
seatunnel-connectors-v2/{connector-amazondynamodb/src/main/java/org/apache/seatunnel/connectors/seatunnel/amazondynamodb/source/AmazonDynamoDBSourceFactory.java
=>
connector-amazondocumentdb/src/main/java/org/apache/seatunnel/connectors/seatunnel/amazondocumentdb/source/AmazonDocumentDBSourceFactory.java}
(54%)
create mode 100644
seatunnel-connectors-v2/connector-amazondocumentdb/src/main/java/org/apache/seatunnel/connectors/seatunnel/amazondocumentdb/source/AmazonDocumentDBSourceReader.java
copy
seatunnel-connectors-v2/{connector-azurecosmosdb/src/main/java/org/apache/seatunnel/connectors/seatunnel/azurecosmosdb/source/AzureCosmosDBSourceSplit.java
=>
connector-amazondocumentdb/src/main/java/org/apache/seatunnel/connectors/seatunnel/amazondocumentdb/source/AmazonDocumentDBSourceSplit.java}
(54%)
create mode 100644
seatunnel-connectors-v2/connector-amazondocumentdb/src/main/java/org/apache/seatunnel/connectors/seatunnel/amazondocumentdb/source/AmazonDocumentDBSourceSplitEnumerator.java
create mode 100644
seatunnel-connectors-v2/connector-amazondocumentdb/src/main/java/org/apache/seatunnel/connectors/seatunnel/amazondocumentdb/source/AmazonDocumentDBSourceState.java
create mode 100644
seatunnel-connectors-v2/connector-amazondocumentdb/src/test/java/org/apache/seatunnel/connectors/seatunnel/amazondocumentdb/AmazonDocumentDBSourceFactoryTest.java
create mode 100644
seatunnel-connectors-v2/connector-amazondocumentdb/src/test/java/org/apache/seatunnel/connectors/seatunnel/amazondocumentdb/DocumentDBItemDeserializerTest.java
create mode 100644
seatunnel-connectors-v2/connector-amazondocumentdb/src/test/java/org/apache/seatunnel/connectors/seatunnel/amazondocumentdb/config/AmazonDocumentDBConfigTest.java
copy
seatunnel-connectors-v2/{connector-azurecosmosdb/src/test/java/org/apache/seatunnel/connectors/seatunnel/azurecosmosdb/source/AzureCosmosDBSourceReaderTest.java
=>
connector-amazondocumentdb/src/test/java/org/apache/seatunnel/connectors/seatunnel/amazondocumentdb/source/AmazonDocumentDBSourceReaderTest.java}
(51%)
create mode 100644
seatunnel-connectors-v2/connector-amazondocumentdb/src/test/java/org/apache/seatunnel/connectors/seatunnel/amazondocumentdb/source/AmazonDocumentDBSourceSplitEnumeratorTest.java
copy seatunnel-e2e/seatunnel-connector-v2-e2e/{connector-azurecosmosdb-e2e =>
connector-amazondocumentdb-e2e}/pom.xml (76%)
create mode 100644
seatunnel-e2e/seatunnel-connector-v2-e2e/connector-amazondocumentdb-e2e/src/test/java/org/apache/seatunnel/e2e/connector/amazondocumentdb/AmazonDocumentDBIT.java
copy
seatunnel-e2e/seatunnel-connector-v2-e2e/{connector-azurecosmosdb-e2e/src/test/resources/azurecosmosdb/azurecosmosdb_source_basic.conf
=>
connector-amazondocumentdb-e2e/src/test/resources/amazondocumentdb_source_basic.conf}
(81%)
copy
seatunnel-e2e/seatunnel-connector-v2-e2e/{connector-azurecosmosdb-e2e/src/test/resources/azurecosmosdb/azurecosmosdb_source_basic.conf
=>
connector-amazondocumentdb-e2e/src/test/resources/amazondocumentdb_source_projection.conf}
(72%)
copy
seatunnel-e2e/seatunnel-connector-v2-e2e/{connector-azurecosmosdb-e2e/src/test/resources/azurecosmosdb/azurecosmosdb_source_pagination.conf
=>
connector-amazondocumentdb-e2e/src/test/resources/amazondocumentdb_source_query_filter.conf}
(68%)
