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 <anco...@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");
