This is an automated email from the ASF dual-hosted git repository.
wanghailin pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/seatunnel.git
The following commit(s) were added to refs/heads/dev by this push:
new 245705d0f7 [Improve][Connector-V2] Change `amazonsqs` to `AmazonSqs`
as connector identifier (#5742)
245705d0f7 is described below
commit 245705d0f7307cb83e09ac265884ce1d2e9419a1
Author: Jia Fan <[email protected]>
AuthorDate: Mon Oct 30 10:08:10 2023 +0800
[Improve][Connector-V2] Change `amazonsqs` to `AmazonSqs` as connector
identifier (#5742)
---
docs/en/connector-v2/sink/AmazonSqs.md | 2 +-
docs/en/connector-v2/source/AmazonSqs.md | 2 +-
.../connectors/seatunnel/amazonsqs/sink/AmazonSqsSink.java | 2 +-
.../connectors/seatunnel/amazonsqs/source/AmazonSqsSource.java | 2 +-
seatunnel-dist/pom.xml | 7 +++++++
.../src/test/resources/amazonsqsIT_source_to_sink.conf | 4 ++--
6 files changed, 13 insertions(+), 6 deletions(-)
diff --git a/docs/en/connector-v2/sink/AmazonSqs.md
b/docs/en/connector-v2/sink/AmazonSqs.md
index 06969b8842..8efabfa395 100644
--- a/docs/en/connector-v2/sink/AmazonSqs.md
+++ b/docs/en/connector-v2/sink/AmazonSqs.md
@@ -75,7 +75,7 @@ source {
}
sink {
- amazonsqs {
+ AmazonSqs {
url = "http://127.0.0.1:8000";
region = "us-east-1"
queue = "queueName"
diff --git a/docs/en/connector-v2/source/AmazonSqs.md
b/docs/en/connector-v2/source/AmazonSqs.md
index a6ec0e5ec4..accd6ec6c6 100644
--- a/docs/en/connector-v2/source/AmazonSqs.md
+++ b/docs/en/connector-v2/source/AmazonSqs.md
@@ -37,7 +37,7 @@ Read data from Amazon SQS.
```bash
source {
- amazonsqs {
+ AmazonSqs {
url = "http://127.0.0.1:4566";
region = "us-east-1"
format = text
diff --git
a/seatunnel-connectors-v2/connector-amazonsqs/src/main/java/org/apache/seatunnel/connectors/seatunnel/amazonsqs/sink/AmazonSqsSink.java
b/seatunnel-connectors-v2/connector-amazonsqs/src/main/java/org/apache/seatunnel/connectors/seatunnel/amazonsqs/sink/AmazonSqsSink.java
index 825771ed59..b18514708f 100644
---
a/seatunnel-connectors-v2/connector-amazonsqs/src/main/java/org/apache/seatunnel/connectors/seatunnel/amazonsqs/sink/AmazonSqsSink.java
+++
b/seatunnel-connectors-v2/connector-amazonsqs/src/main/java/org/apache/seatunnel/connectors/seatunnel/amazonsqs/sink/AmazonSqsSink.java
@@ -50,7 +50,7 @@ public class AmazonSqsSink extends
AbstractSimpleSink<SeaTunnelRow, Void> {
@Override
public String getPluginName() {
- return "amazonsqs";
+ return "AmazonSqs";
}
public AmazonSqsSink(ReadonlyConfig pluginConfig, SeaTunnelRowType
typeInfo) {
diff --git
a/seatunnel-connectors-v2/connector-amazonsqs/src/main/java/org/apache/seatunnel/connectors/seatunnel/amazonsqs/source/AmazonSqsSource.java
b/seatunnel-connectors-v2/connector-amazonsqs/src/main/java/org/apache/seatunnel/connectors/seatunnel/amazonsqs/source/AmazonSqsSource.java
index 45daa0afe3..79abf65edd 100644
---
a/seatunnel-connectors-v2/connector-amazonsqs/src/main/java/org/apache/seatunnel/connectors/seatunnel/amazonsqs/source/AmazonSqsSource.java
+++
b/seatunnel-connectors-v2/connector-amazonsqs/src/main/java/org/apache/seatunnel/connectors/seatunnel/amazonsqs/source/AmazonSqsSource.java
@@ -69,7 +69,7 @@ public class AmazonSqsSource extends
AbstractSingleSplitSource<SeaTunnelRow>
@Override
public String getPluginName() {
- return "amazonsqs";
+ return "AmazonSqs";
}
@Override
diff --git a/seatunnel-dist/pom.xml b/seatunnel-dist/pom.xml
index a3f6ef2155..b8a99118ab 100644
--- a/seatunnel-dist/pom.xml
+++ b/seatunnel-dist/pom.xml
@@ -521,6 +521,13 @@
<scope>provided</scope>
</dependency>
+ <dependency>
+ <groupId>org.apache.seatunnel</groupId>
+ <artifactId>connector-amazonsqs</artifactId>
+ <version>${project.version}</version>
+ <scope>provided</scope>
+ </dependency>
+
<!-- jdbc driver -->
<dependency>
<groupId>com.aliyun.phoenix</groupId>
diff --git
a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-amazonsqs-e2e/src/test/resources/amazonsqsIT_source_to_sink.conf
b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-amazonsqs-e2e/src/test/resources/amazonsqsIT_source_to_sink.conf
index ced014bea3..ce73058d4d 100644
---
a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-amazonsqs-e2e/src/test/resources/amazonsqsIT_source_to_sink.conf
+++
b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-amazonsqs-e2e/src/test/resources/amazonsqsIT_source_to_sink.conf
@@ -26,7 +26,7 @@ env {
source {
# This is a example source plugin **only for test and demonstrate the
feature source plugin**
- amazonsqs {
+ AmazonSqs {
url = "http://sqs-host:4566/000000000000/source_queue";
access_key_id = "1234"
secret_access_key = "abcd"
@@ -46,7 +46,7 @@ transform {
sink {
# This is a example source plugin **only for test and demonstrate the feature
sink plugin**
- amazonsqs {
+ AmazonSqs {
url = "http://sqs-host:4566/000000000000/sink_queue";
access_key_id = "1234"
secret_access_key = "abcd"
