You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by ac...@apache.org on 2020/09/10 07:31:58 UTC
[camel-kafka-connector] branch transformers created (now 77df0f7)
This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a change to branch transformers
in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git.
at 77df0f7 Regen docs
This branch includes the following new commits:
new dcbdcc5 Transformers: Better naming for packages and classes
new 77df0f7 Regen docs
The 2 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
[camel-kafka-connector] 01/02: Transformers: Better naming for
packages and classes
Posted by ac...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a commit to branch transformers
in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git
commit dcbdcc51321ec5e9cbc1cca644d2d365abb0ce7b
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Thu Sep 10 09:27:41 2020 +0200
Transformers: Better naming for packages and classes
---
.../S3ObjectTransforms.java => transformers/S3ObjectTransformer.java} | 4 ++--
.../S3ObjectTransformers.java} | 4 ++--
.../SQSKeySetterTransformers.java} | 4 ++--
3 files changed, 6 insertions(+), 6 deletions(-)
diff --git a/connectors/camel-aws-s3-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/awss3/transforms/S3ObjectTransforms.java b/connectors/camel-aws-s3-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/awss3/transformers/S3ObjectTransformer.java
similarity index 92%
rename from connectors/camel-aws-s3-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/awss3/transforms/S3ObjectTransforms.java
rename to connectors/camel-aws-s3-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/awss3/transformers/S3ObjectTransformer.java
index a40dacc..3dd9339 100644
--- a/connectors/camel-aws-s3-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/awss3/transforms/S3ObjectTransforms.java
+++ b/connectors/camel-aws-s3-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/awss3/transformers/S3ObjectTransformer.java
@@ -14,7 +14,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package org.apache.camel.kafkaconnector.awss3.transforms;
+package org.apache.camel.kafkaconnector.awss3.transformers;
import java.util.Map;
@@ -25,7 +25,7 @@ import org.apache.kafka.connect.connector.ConnectRecord;
import org.apache.kafka.connect.data.Schema;
import org.apache.kafka.connect.transforms.Transformation;
-public class S3ObjectTransforms<R extends ConnectRecord<R>> implements Transformation<R> {
+public class S3ObjectTransformer<R extends ConnectRecord<R>> implements Transformation<R> {
public static final ConfigDef CONFIG_DEF = new ConfigDef()
.define("test", ConfigDef.Type.STRING, "test", ConfigDef.Importance.MEDIUM, "Transform the content of a bucket into a string ");
diff --git a/connectors/camel-aws2-s3-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/aws2s3/transforms/S3ObjectTransforms.java b/connectors/camel-aws2-s3-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/aws2s3/transformers/S3ObjectTransformers.java
similarity index 93%
rename from connectors/camel-aws2-s3-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/aws2s3/transforms/S3ObjectTransforms.java
rename to connectors/camel-aws2-s3-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/aws2s3/transformers/S3ObjectTransformers.java
index 1023f20..fa6e80b 100644
--- a/connectors/camel-aws2-s3-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/aws2s3/transforms/S3ObjectTransforms.java
+++ b/connectors/camel-aws2-s3-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/aws2s3/transformers/S3ObjectTransformers.java
@@ -14,7 +14,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package org.apache.camel.kafkaconnector.aws2s3.transforms;
+package org.apache.camel.kafkaconnector.aws2s3.transformers;
import java.util.Map;
@@ -25,7 +25,7 @@ import org.apache.kafka.connect.data.Schema;
import org.apache.kafka.connect.transforms.Transformation;
import software.amazon.awssdk.core.ResponseInputStream;
-public class S3ObjectTransforms<R extends ConnectRecord<R>> implements Transformation<R> {
+public class S3ObjectTransformers<R extends ConnectRecord<R>> implements Transformation<R> {
public static final ConfigDef CONFIG_DEF = new ConfigDef().define("test", ConfigDef.Type.STRING, "test", ConfigDef.Importance.MEDIUM,
"Transform the content of a bucket into a string ");
diff --git a/connectors/camel-aws2-sqs-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/aws2sqs/transforms/SQSKeySetterTransform.java b/connectors/camel-aws2-sqs-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/aws2sqs/transformers/SQSKeySetterTransformers.java
similarity index 92%
rename from connectors/camel-aws2-sqs-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/aws2sqs/transforms/SQSKeySetterTransform.java
rename to connectors/camel-aws2-sqs-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/aws2sqs/transformers/SQSKeySetterTransformers.java
index 2c1815c..7da0da4 100644
--- a/connectors/camel-aws2-sqs-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/aws2sqs/transforms/SQSKeySetterTransform.java
+++ b/connectors/camel-aws2-sqs-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/aws2sqs/transformers/SQSKeySetterTransformers.java
@@ -14,7 +14,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package org.apache.camel.kafkaconnector.aws2sqs.transforms;
+package org.apache.camel.kafkaconnector.aws2sqs.transformers;
import java.util.Map;
@@ -24,7 +24,7 @@ import org.apache.kafka.connect.data.Schema;
import org.apache.kafka.connect.header.Headers;
import org.apache.kafka.connect.transforms.Transformation;
-public class SQSKeySetterTransform<R extends ConnectRecord<R>> implements Transformation<R> {
+public class SQSKeySetterTransformers<R extends ConnectRecord<R>> implements Transformation<R> {
public static final ConfigDef CONFIG_DEF = new ConfigDef()
.define("test", ConfigDef.Type.STRING, "test", ConfigDef.Importance.MEDIUM, "Fetch the Camel.CamelAwsSqsMessageId header and set it as the key for the kafka record");
[camel-kafka-connector] 02/02: Regen docs
Posted by ac...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a commit to branch transformers
in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git
commit 77df0f7024cef9450adf2c42994887697ba72e5b
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Thu Sep 10 09:31:13 2020 +0200
Regen docs
---
.../src/main/docs/camel-aws-s3-kafka-sink-connector.adoc | 9 +--------
.../src/main/docs/camel-aws-s3-kafka-source-connector.adoc | 9 +--------
.../src/main/docs/camel-aws2-s3-kafka-sink-connector.adoc | 9 +--------
.../src/main/docs/camel-aws2-s3-kafka-source-connector.adoc | 9 +--------
.../ROOT/pages/connectors/camel-aws-s3-kafka-sink-connector.adoc | 9 +--------
.../pages/connectors/camel-aws-s3-kafka-source-connector.adoc | 9 +--------
.../pages/connectors/camel-aws2-s3-kafka-sink-connector.adoc | 9 +--------
.../pages/connectors/camel-aws2-s3-kafka-source-connector.adoc | 9 +--------
8 files changed, 8 insertions(+), 64 deletions(-)
diff --git a/connectors/camel-aws-s3-kafka-connector/src/main/docs/camel-aws-s3-kafka-sink-connector.adoc b/connectors/camel-aws-s3-kafka-connector/src/main/docs/camel-aws-s3-kafka-sink-connector.adoc
index efa6c01..104e65a 100644
--- a/connectors/camel-aws-s3-kafka-connector/src/main/docs/camel-aws-s3-kafka-sink-connector.adoc
+++ b/connectors/camel-aws-s3-kafka-connector/src/main/docs/camel-aws-s3-kafka-sink-connector.adoc
@@ -111,17 +111,10 @@ org.apache.camel.kafkaconnector.awss3.converters.S3ObjectConverter
-The camel-aws-s3 sink connector supports 1 transforms out of the box, which are listed below.
+The camel-aws-s3 sink connector has no transforms out of the box.
-[source,java]
-----
-
-org.apache.camel.kafkaconnector.awss3.transforms.S3ObjectTransforms
-
-----
-
The camel-aws-s3 sink connector has no aggregation strategies out of the box.
diff --git a/connectors/camel-aws-s3-kafka-connector/src/main/docs/camel-aws-s3-kafka-source-connector.adoc b/connectors/camel-aws-s3-kafka-connector/src/main/docs/camel-aws-s3-kafka-source-connector.adoc
index 28531e9..a56b6b7 100644
--- a/connectors/camel-aws-s3-kafka-connector/src/main/docs/camel-aws-s3-kafka-source-connector.adoc
+++ b/connectors/camel-aws-s3-kafka-connector/src/main/docs/camel-aws-s3-kafka-source-connector.adoc
@@ -125,17 +125,10 @@ org.apache.camel.kafkaconnector.awss3.converters.S3ObjectConverter
-The camel-aws-s3 sink connector supports 1 transforms out of the box, which are listed below.
+The camel-aws-s3 sink connector has no transforms out of the box.
-[source,java]
-----
-
-org.apache.camel.kafkaconnector.awss3.transforms.S3ObjectTransforms
-
-----
-
The camel-aws-s3 sink connector has no aggregation strategies out of the box.
diff --git a/connectors/camel-aws2-s3-kafka-connector/src/main/docs/camel-aws2-s3-kafka-sink-connector.adoc b/connectors/camel-aws2-s3-kafka-connector/src/main/docs/camel-aws2-s3-kafka-sink-connector.adoc
index 651d502..3fc5887 100644
--- a/connectors/camel-aws2-s3-kafka-connector/src/main/docs/camel-aws2-s3-kafka-sink-connector.adoc
+++ b/connectors/camel-aws2-s3-kafka-connector/src/main/docs/camel-aws2-s3-kafka-sink-connector.adoc
@@ -107,17 +107,10 @@ org.apache.camel.kafkaconnector.aws2s3.converters.S3ObjectConverter
-The camel-aws2-s3 sink connector supports 1 transforms out of the box, which are listed below.
+The camel-aws2-s3 sink connector has no transforms out of the box.
-[source,java]
-----
-
-org.apache.camel.kafkaconnector.aws2s3.transforms.S3ObjectTransforms
-
-----
-
The camel-aws2-s3 sink connector has no aggregation strategies out of the box.
diff --git a/connectors/camel-aws2-s3-kafka-connector/src/main/docs/camel-aws2-s3-kafka-source-connector.adoc b/connectors/camel-aws2-s3-kafka-connector/src/main/docs/camel-aws2-s3-kafka-source-connector.adoc
index c7acb6d..d02e099 100644
--- a/connectors/camel-aws2-s3-kafka-connector/src/main/docs/camel-aws2-s3-kafka-source-connector.adoc
+++ b/connectors/camel-aws2-s3-kafka-connector/src/main/docs/camel-aws2-s3-kafka-source-connector.adoc
@@ -131,17 +131,10 @@ org.apache.camel.kafkaconnector.aws2s3.converters.S3ObjectConverter
-The camel-aws2-s3 sink connector supports 1 transforms out of the box, which are listed below.
+The camel-aws2-s3 sink connector has no transforms out of the box.
-[source,java]
-----
-
-org.apache.camel.kafkaconnector.aws2s3.transforms.S3ObjectTransforms
-
-----
-
The camel-aws2-s3 sink connector has no aggregation strategies out of the box.
diff --git a/docs/modules/ROOT/pages/connectors/camel-aws-s3-kafka-sink-connector.adoc b/docs/modules/ROOT/pages/connectors/camel-aws-s3-kafka-sink-connector.adoc
index efa6c01..104e65a 100644
--- a/docs/modules/ROOT/pages/connectors/camel-aws-s3-kafka-sink-connector.adoc
+++ b/docs/modules/ROOT/pages/connectors/camel-aws-s3-kafka-sink-connector.adoc
@@ -111,17 +111,10 @@ org.apache.camel.kafkaconnector.awss3.converters.S3ObjectConverter
-The camel-aws-s3 sink connector supports 1 transforms out of the box, which are listed below.
+The camel-aws-s3 sink connector has no transforms out of the box.
-[source,java]
-----
-
-org.apache.camel.kafkaconnector.awss3.transforms.S3ObjectTransforms
-
-----
-
The camel-aws-s3 sink connector has no aggregation strategies out of the box.
diff --git a/docs/modules/ROOT/pages/connectors/camel-aws-s3-kafka-source-connector.adoc b/docs/modules/ROOT/pages/connectors/camel-aws-s3-kafka-source-connector.adoc
index 28531e9..a56b6b7 100644
--- a/docs/modules/ROOT/pages/connectors/camel-aws-s3-kafka-source-connector.adoc
+++ b/docs/modules/ROOT/pages/connectors/camel-aws-s3-kafka-source-connector.adoc
@@ -125,17 +125,10 @@ org.apache.camel.kafkaconnector.awss3.converters.S3ObjectConverter
-The camel-aws-s3 sink connector supports 1 transforms out of the box, which are listed below.
+The camel-aws-s3 sink connector has no transforms out of the box.
-[source,java]
-----
-
-org.apache.camel.kafkaconnector.awss3.transforms.S3ObjectTransforms
-
-----
-
The camel-aws-s3 sink connector has no aggregation strategies out of the box.
diff --git a/docs/modules/ROOT/pages/connectors/camel-aws2-s3-kafka-sink-connector.adoc b/docs/modules/ROOT/pages/connectors/camel-aws2-s3-kafka-sink-connector.adoc
index 651d502..3fc5887 100644
--- a/docs/modules/ROOT/pages/connectors/camel-aws2-s3-kafka-sink-connector.adoc
+++ b/docs/modules/ROOT/pages/connectors/camel-aws2-s3-kafka-sink-connector.adoc
@@ -107,17 +107,10 @@ org.apache.camel.kafkaconnector.aws2s3.converters.S3ObjectConverter
-The camel-aws2-s3 sink connector supports 1 transforms out of the box, which are listed below.
+The camel-aws2-s3 sink connector has no transforms out of the box.
-[source,java]
-----
-
-org.apache.camel.kafkaconnector.aws2s3.transforms.S3ObjectTransforms
-
-----
-
The camel-aws2-s3 sink connector has no aggregation strategies out of the box.
diff --git a/docs/modules/ROOT/pages/connectors/camel-aws2-s3-kafka-source-connector.adoc b/docs/modules/ROOT/pages/connectors/camel-aws2-s3-kafka-source-connector.adoc
index c7acb6d..d02e099 100644
--- a/docs/modules/ROOT/pages/connectors/camel-aws2-s3-kafka-source-connector.adoc
+++ b/docs/modules/ROOT/pages/connectors/camel-aws2-s3-kafka-source-connector.adoc
@@ -131,17 +131,10 @@ org.apache.camel.kafkaconnector.aws2s3.converters.S3ObjectConverter
-The camel-aws2-s3 sink connector supports 1 transforms out of the box, which are listed below.
+The camel-aws2-s3 sink connector has no transforms out of the box.
-[source,java]
-----
-
-org.apache.camel.kafkaconnector.aws2s3.transforms.S3ObjectTransforms
-
-----
-
The camel-aws2-s3 sink connector has no aggregation strategies out of the box.