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/10/14 10:43:21 UTC
[camel-kafka-connector] 01/05: Rename all transformers, converters,
aggregationStrategies to reflect the maning convention we have -
aws-s3
This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a commit to branch conv-aggr-transform-alignment
in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git
commit d675ab0e88c76f147a3280e7a2bd3395345bf176
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Wed Oct 14 11:41:25 2020 +0200
Rename all transformers, converters, aggregationStrategies to reflect the maning convention we have - aws-s3
---
.../transformers/{S3ObjectTransformer.java => S3ObjectTransforms.java} | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/connectors/camel-aws-s3-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/awss3/transformers/S3ObjectTransformer.java b/connectors/camel-aws-s3-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/awss3/transformers/S3ObjectTransforms.java
similarity index 95%
rename from connectors/camel-aws-s3-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/awss3/transformers/S3ObjectTransformer.java
rename to connectors/camel-aws-s3-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/awss3/transformers/S3ObjectTransforms.java
index 3dd9339..918770e 100644
--- a/connectors/camel-aws-s3-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/awss3/transformers/S3ObjectTransformer.java
+++ b/connectors/camel-aws-s3-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/awss3/transformers/S3ObjectTransforms.java
@@ -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 S3ObjectTransformer<R extends ConnectRecord<R>> implements Transformation<R> {
+public class S3ObjectTransforms<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 ");