This is an automated email from the ASF dual-hosted git repository.
gaojun2048 pushed a change to branch dev
in repository https://gitbox.apache.org/repos/asf/incubator-seatunnel.git
from edb14108a [Bug] [seatunnel-connectors-flink-kafka] When json or avro
are selected for kafka schema, a ClassCastException error is reported (#3243)
add 183bac02f [Feature][Connector-V2] [Amazondynamodb Connector]add
amazondynamodb source & sink connnector (#3166)
No new revisions were added by this update.
Summary of changes:
docs/en/connector-v2/sink/Amazondynamodb.md | 69 ++++
docs/en/connector-v2/source/Amazondynamodb.md | 108 +++++++
plugin-mapping.properties | 4 +-
.../pom.xml | 33 +-
.../config/AmazondynamodbConfig.java | 20 +-
.../config/AmazondynamodbSourceOptions.java | 68 ++++
.../serialize/DefaultSeaTunnelRowDeserializer.java | 135 ++++++++
.../serialize/DefaultSeaTunnelRowSerializer.java | 147 +++++++++
.../serialize}/SeaTunnelRowDeserializer.java | 9 +-
.../serialize/SeaTunnelRowSerializer.java | 6 +-
.../amazondynamodb/sink/AmazondynamodbSink.java} | 35 ++-
.../amazondynamodb/sink/AmazondynamodbWriter.java} | 28 +-
.../amazondynamodb/sink/DdynamoDbSinkClient.java | 134 ++++++++
.../source/AmazondynamodbSource.java} | 52 ++-
.../source/AmazondynamodbSourceReader.java | 85 +++++
.../seatunnel/common/config/CommonConfig.java} | 6 +-
seatunnel-connectors-v2/pom.xml | 1 +
seatunnel-dist/pom.xml | 6 +
.../pom.xml | 28 +-
.../connector/amazondynamodb/AmazondynamodbIT.java | 349 +++++++++++++++++++++
.../amazondynamodbIT_source_to_sink.conf} | 44 +--
seatunnel-e2e/seatunnel-connector-v2-e2e/pom.xml | 3 +-
tools/update_modules_check/update_modules_check.py | 10 +-
23 files changed, 1253 insertions(+), 127 deletions(-)
create mode 100644 docs/en/connector-v2/sink/Amazondynamodb.md
create mode 100644 docs/en/connector-v2/source/Amazondynamodb.md
copy seatunnel-connectors-v2/{connector-mongodb =>
connector-amazondynamodb}/pom.xml (70%)
copy
seatunnel-api/src/main/java/org/apache/seatunnel/api/serialization/SerializationSchema.java
=>
seatunnel-connectors-v2/connector-amazondynamodb/src/main/java/org/apache/seatunnel/connectors/seatunnel/amazondynamodb/config/AmazondynamodbConfig.java
(60%)
create mode 100644
seatunnel-connectors-v2/connector-amazondynamodb/src/main/java/org/apache/seatunnel/connectors/seatunnel/amazondynamodb/config/AmazondynamodbSourceOptions.java
create mode 100644
seatunnel-connectors-v2/connector-amazondynamodb/src/main/java/org/apache/seatunnel/connectors/seatunnel/amazondynamodb/serialize/DefaultSeaTunnelRowDeserializer.java
create mode 100644
seatunnel-connectors-v2/connector-amazondynamodb/src/main/java/org/apache/seatunnel/connectors/seatunnel/amazondynamodb/serialize/DefaultSeaTunnelRowSerializer.java
copy
seatunnel-connectors-v2/{connector-elasticsearch/src/main/java/org/apache/seatunnel/connectors/seatunnel/elasticsearch/serialize/source
=>
connector-amazondynamodb/src/main/java/org/apache/seatunnel/connectors/seatunnel/amazondynamodb/serialize}/SeaTunnelRowDeserializer.java
(79%)
copy
seatunnel-connectors-v2/{connector-elasticsearch/src/main/java/org/apache/seatunnel/connectors/seatunnel/elasticsearch
=>
connector-amazondynamodb/src/main/java/org/apache/seatunnel/connectors/seatunnel/amazondynamodb}/serialize/SeaTunnelRowSerializer.java
(81%)
copy
seatunnel-connectors-v2/{connector-redis/src/main/java/org/apache/seatunnel/connectors/seatunnel/redis/sink/RedisSink.java
=>
connector-amazondynamodb/src/main/java/org/apache/seatunnel/connectors/seatunnel/amazondynamodb/sink/AmazondynamodbSink.java}
(64%)
copy
seatunnel-connectors-v2/{connector-socket/src/main/java/org/apache/seatunnel/connectors/seatunnel/socket/sink/SocketSinkWriter.java
=>
connector-amazondynamodb/src/main/java/org/apache/seatunnel/connectors/seatunnel/amazondynamodb/sink/AmazondynamodbWriter.java}
(54%)
create mode 100644
seatunnel-connectors-v2/connector-amazondynamodb/src/main/java/org/apache/seatunnel/connectors/seatunnel/amazondynamodb/sink/DdynamoDbSinkClient.java
copy
seatunnel-connectors-v2/{connector-redis/src/main/java/org/apache/seatunnel/connectors/seatunnel/redis/source/RedisSource.java
=>
connector-amazondynamodb/src/main/java/org/apache/seatunnel/connectors/seatunnel/amazondynamodb/source/AmazondynamodbSource.java}
(59%)
create mode 100644
seatunnel-connectors-v2/connector-amazondynamodb/src/main/java/org/apache/seatunnel/connectors/seatunnel/amazondynamodb/source/AmazondynamodbSourceReader.java
copy
seatunnel-connectors-v2/{connector-neo4j/src/main/java/org/apache/seatunnel/connectors/seatunnel/neo4j/config/Neo4jSourceConfig.java
=>
connector-common/src/main/java/org/apache/seatunnel/connectors/seatunnel/common/config/CommonConfig.java}
(85%)
copy seatunnel-e2e/seatunnel-connector-v2-e2e/{connector-influxdb-e2e =>
connector-amazondynamodb-e2e}/pom.xml (69%)
create mode 100644
seatunnel-e2e/seatunnel-connector-v2-e2e/connector-amazondynamodb-e2e/src/test/java/org/apache/seatunnel/e2e/connector/amazondynamodb/AmazondynamodbIT.java
copy
seatunnel-e2e/{seatunnel-spark-connector-v2-e2e/connector-mongodb-spark-e2e/src/test/resources/mongodb/fake_to_mongodb.conf
=>
seatunnel-connector-v2-e2e/connector-amazondynamodb-e2e/src/test/resources/amazondynamodbIT_source_to_sink.conf}
(66%)
