Rename transform

Author: murakami-ta

transforms/src/main/java/com/reproio/kafka/connect/transforms/MapToJsonString.java renamed to transforms/src/main/java/com/reproio/kafka/connect/transforms/AvroMapToJsonString.java

@@ -12,7 +12,7 @@
 import org.apache.kafka.connect.data.Struct;
 import org.apache.kafka.connect.transforms.Transformation;
 
-public abstract class MapToJsonString<R extends ConnectRecord<R>> implements Transformation<R> {
+public abstract class AvroMapToJsonString<R extends ConnectRecord<R>> implements Transformation<R> {
 
   public static final String FIELD_CONFIG = "field";
   public static final ObjectMapper mapper = new ObjectMapper();
@@ -28,7 +28,7 @@ public void configure(Map<String, ?> props) {
     fieldName = config.getString(FIELD_CONFIG);
   }
 
-  protected MapToJsonString() {}
+  protected AvroMapToJsonString() {}
 
   @Override
   public R apply(R record) {
@@ -117,7 +117,7 @@ public void close() {}
 
   protected abstract R newRecord(R record, Schema updatedSchema, Object updatedValue);
 
-  public static class Key<R extends ConnectRecord<R>> extends MapToJsonString<R> {
+  public static class Key<R extends ConnectRecord<R>> extends AvroMapToJsonString<R> {
     @Override
     protected Schema operatingSchema(R record) {
       return record.keySchema();
@@ -141,7 +141,7 @@ protected R newRecord(R record, Schema updatedSchema, Object updatedValue) {
     }
   }
 
-  public static class Value<R extends ConnectRecord<R>> extends MapToJsonString<R> {
+  public static class Value<R extends ConnectRecord<R>> extends AvroMapToJsonString<R> {
     @Override
     protected Schema operatingSchema(R record) {
       return record.valueSchema();

transforms/src/test/java/com/reproio/kafka/connect/transforms/MapToJsonStringTest.java renamed to transforms/src/test/java/com/reproio/kafka/connect/transforms/AvroMapToJsonStringTest.java

@@ -11,7 +11,7 @@
 import org.junit.jupiter.api.Test;
 
 @SuppressWarnings("resource")
-class MapUnionToStringTest {
+class AvroMapToJsonStringTest {
 
   @Test
   void transformsValue_UnionMap() {
@@ -28,7 +28,7 @@ void transformsValue_UnionMap() {
 
     var in = new SinkRecord("topic-a", 0, null, null, valueSchema, value, 123L);
 
-    MapToJsonString.Value<SinkRecord> transformer = new MapToJsonString.Value<>();
+    AvroMapToJsonString.Value<SinkRecord> transformer = new AvroMapToJsonString.Value<>();
     transformer.configure(Map.of("field", "properties"));
 
     var out = transformer.apply(in);
@@ -69,7 +69,7 @@ void transformsValue_StringMap() {
 
     var in = new SinkRecord("topic-a", 0, null, null, valueSchema, value, 123L);
 
-    MapToJsonString.Value<SinkRecord> transformer = new MapToJsonString.Value<>();
+    AvroMapToJsonString.Value<SinkRecord> transformer = new AvroMapToJsonString.Value<>();
     transformer.configure(Map.of("field", "properties"));
 
     var out = transformer.apply(in);