This is an automated email from the ASF dual-hosted git repository. acosentino pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git
commit 58e0d6ed4f7f551c87da07116bccdb41ffbace00 Author: Andrea Tarocchi <[email protected]> AuthorDate: Tue Nov 17 17:13:35 2020 +0100 related to #715: renamed PojoToSchemaAndStructTransform to SourcePojoToSchemaAndStructTransform --- ...a => SourcePojoToSchemaAndStructTransform.java} | 4 +-- ... SourcePojoToSchemaAndStructTransformTest.java} | 42 +++++++++++----------- 2 files changed, 23 insertions(+), 23 deletions(-) diff --git a/core/src/main/java/org/apache/camel/kafkaconnector/transforms/PojoToSchemaAndStructTransform.java b/core/src/main/java/org/apache/camel/kafkaconnector/transforms/SourcePojoToSchemaAndStructTransform.java similarity index 96% rename from core/src/main/java/org/apache/camel/kafkaconnector/transforms/PojoToSchemaAndStructTransform.java rename to core/src/main/java/org/apache/camel/kafkaconnector/transforms/SourcePojoToSchemaAndStructTransform.java index 1ecf48f..6f0f850 100644 --- a/core/src/main/java/org/apache/camel/kafkaconnector/transforms/PojoToSchemaAndStructTransform.java +++ b/core/src/main/java/org/apache/camel/kafkaconnector/transforms/SourcePojoToSchemaAndStructTransform.java @@ -43,8 +43,8 @@ import org.apache.kafka.connect.transforms.Transformation; import org.slf4j.Logger; import org.slf4j.LoggerFactory; -public class PojoToSchemaAndStructTransform <R extends ConnectRecord<R>> implements Transformation<R> { - private static final Logger LOG = LoggerFactory.getLogger(PojoToSchemaAndStructTransform.class); +public class SourcePojoToSchemaAndStructTransform<R extends ConnectRecord<R>> implements Transformation<R> { + private static final Logger LOG = LoggerFactory.getLogger(SourcePojoToSchemaAndStructTransform.class); private static final ObjectMapper MAPPER = new ObjectMapper(new AvroFactory()); private AvroData avroData; diff --git a/core/src/test/java/org/apache/camel/kafkaconnector/transforms/PojoToSchemaAndStructTransformTest.java b/core/src/test/java/org/apache/camel/kafkaconnector/transforms/SourcePojoToSchemaAndStructTransformTest.java similarity index 76% rename from core/src/test/java/org/apache/camel/kafkaconnector/transforms/PojoToSchemaAndStructTransformTest.java rename to core/src/test/java/org/apache/camel/kafkaconnector/transforms/SourcePojoToSchemaAndStructTransformTest.java index e378eab..529c45f 100644 --- a/core/src/test/java/org/apache/camel/kafkaconnector/transforms/PojoToSchemaAndStructTransformTest.java +++ b/core/src/test/java/org/apache/camel/kafkaconnector/transforms/SourcePojoToSchemaAndStructTransformTest.java @@ -34,12 +34,12 @@ import static org.junit.jupiter.api.Assertions.assertEquals; import static org.junit.jupiter.api.Assertions.assertThrows; import static org.junit.jupiter.api.Assertions.assertTrue; -public class PojoToSchemaAndStructTransformTest { +public class SourcePojoToSchemaAndStructTransformTest { @Test public void testRecordValueConversion() { - PojoToSchemaAndStructTransform pojoToSchemaAndStructTransform = new PojoToSchemaAndStructTransform(); - pojoToSchemaAndStructTransform.configure(Collections.emptyMap()); + SourcePojoToSchemaAndStructTransform sourcePojoToSchemaAndStructTransform = new SourcePojoToSchemaAndStructTransform(); + sourcePojoToSchemaAndStructTransform.configure(Collections.emptyMap()); SlackMessage sm = new SlackMessage(); @@ -63,7 +63,7 @@ public class PojoToSchemaAndStructTransformTest { Schema.STRING_SCHEMA, "testKeyValue", Schema.BYTES_SCHEMA, sm); - ConnectRecord transformedCr = pojoToSchemaAndStructTransform.apply(cr); + ConnectRecord transformedCr = sourcePojoToSchemaAndStructTransform.apply(cr); assertEquals("testTopic", transformedCr.topic()); assertEquals(Schema.STRING_SCHEMA, transformedCr.keySchema()); @@ -85,8 +85,8 @@ public class PojoToSchemaAndStructTransformTest { @Test public void testMapValueConversion() { - PojoToSchemaAndStructTransform pojoToSchemaAndStructTransform = new PojoToSchemaAndStructTransform(); - pojoToSchemaAndStructTransform.configure(Collections.emptyMap()); + SourcePojoToSchemaAndStructTransform sourcePojoToSchemaAndStructTransform = new SourcePojoToSchemaAndStructTransform(); + sourcePojoToSchemaAndStructTransform.configure(Collections.emptyMap()); PojoWithMap pwm = new PojoWithMap(); pwm.addToMap("ciao", 9); @@ -95,7 +95,7 @@ public class PojoToSchemaAndStructTransformTest { Schema.STRING_SCHEMA, "testKeyValue", Schema.BYTES_SCHEMA, pwm); - ConnectRecord transformedCr = pojoToSchemaAndStructTransform.apply(cr); + ConnectRecord transformedCr = sourcePojoToSchemaAndStructTransform.apply(cr); assertEquals("testTopic", transformedCr.topic()); assertEquals(Schema.STRING_SCHEMA, transformedCr.keySchema()); @@ -113,8 +113,8 @@ public class PojoToSchemaAndStructTransformTest { @Test() public void testNotPojoConversion() { - PojoToSchemaAndStructTransform pojoToSchemaAndStructTransform = new PojoToSchemaAndStructTransform(); - pojoToSchemaAndStructTransform.configure(Collections.emptyMap()); + SourcePojoToSchemaAndStructTransform sourcePojoToSchemaAndStructTransform = new SourcePojoToSchemaAndStructTransform(); + sourcePojoToSchemaAndStructTransform.configure(Collections.emptyMap()); Map map = Collections.singletonMap("ciao", 9); @@ -123,27 +123,27 @@ public class PojoToSchemaAndStructTransformTest { Schema.BYTES_SCHEMA, map); assertThrows(ConnectException.class, () -> { - pojoToSchemaAndStructTransform.apply(cr); + sourcePojoToSchemaAndStructTransform.apply(cr); }); } @Test() public void testNullValueConversion() { - PojoToSchemaAndStructTransform pojoToSchemaAndStructTransform = new PojoToSchemaAndStructTransform(); - pojoToSchemaAndStructTransform.configure(Collections.emptyMap()); + SourcePojoToSchemaAndStructTransform sourcePojoToSchemaAndStructTransform = new SourcePojoToSchemaAndStructTransform(); + sourcePojoToSchemaAndStructTransform.configure(Collections.emptyMap()); ConnectRecord cr = new SourceRecord(null, null, "testTopic", Schema.STRING_SCHEMA, "testKeyValue", Schema.BYTES_SCHEMA, null); - ConnectRecord transformedCr = pojoToSchemaAndStructTransform.apply(cr); + ConnectRecord transformedCr = sourcePojoToSchemaAndStructTransform.apply(cr); assertEquals(cr, transformedCr); } @Test() public void testConversionCache() { - PojoToSchemaAndStructTransform pojoToSchemaAndStructTransform = new PojoToSchemaAndStructTransform(); - pojoToSchemaAndStructTransform.configure(Collections.emptyMap()); + SourcePojoToSchemaAndStructTransform sourcePojoToSchemaAndStructTransform = new SourcePojoToSchemaAndStructTransform(); + sourcePojoToSchemaAndStructTransform.configure(Collections.emptyMap()); PojoWithMap pwm = new PojoWithMap(); pwm.addToMap("ciao", 9); @@ -152,12 +152,12 @@ public class PojoToSchemaAndStructTransformTest { Schema.STRING_SCHEMA, "testKeyValue", Schema.BYTES_SCHEMA, pwm); - assertEquals(0, pojoToSchemaAndStructTransform.getCache().keySet().size()); - pojoToSchemaAndStructTransform.apply(cr); - assertEquals(1, pojoToSchemaAndStructTransform.getCache().keySet().size()); - ConnectRecord transformedCr = pojoToSchemaAndStructTransform.apply(cr); - assertEquals(1, pojoToSchemaAndStructTransform.getCache().keySet().size()); - assertTrue(pojoToSchemaAndStructTransform.getCache().keySet().contains(PojoWithMap.class.getCanonicalName())); + assertEquals(0, sourcePojoToSchemaAndStructTransform.getCache().keySet().size()); + sourcePojoToSchemaAndStructTransform.apply(cr); + assertEquals(1, sourcePojoToSchemaAndStructTransform.getCache().keySet().size()); + ConnectRecord transformedCr = sourcePojoToSchemaAndStructTransform.apply(cr); + assertEquals(1, sourcePojoToSchemaAndStructTransform.getCache().keySet().size()); + assertTrue(sourcePojoToSchemaAndStructTransform.getCache().keySet().contains(PojoWithMap.class.getCanonicalName())); } private void atLeastOneFieldWithGivenValueExists(List structs, String fieldName, String fieldExpectedValue) {
