Rename AvroConfluentContentSchemaProvider

Rename AvroConfluentContentSchemaProvider to ConfluentContentSchemaProvider

Author: chenjian2664

plugin/trino-kafka/src/main/java/io/trino/plugin/kafka/schema/confluent/AvroConfluentContentSchemaProvider.java renamed to plugin/trino-kafka/src/main/java/io/trino/plugin/kafka/schema/confluent/ConfluentContentSchemaProvider.java

@@ -29,13 +29,13 @@
 import static java.lang.String.format;
 import static java.util.Objects.requireNonNull;
 
-public class AvroConfluentContentSchemaProvider
+public class ConfluentContentSchemaProvider
         extends AbstractContentSchemaProvider
 {
     private final SchemaRegistryClient schemaRegistryClient;
 
     @Inject
-    public AvroConfluentContentSchemaProvider(SchemaRegistryClient schemaRegistryClient)
+    public ConfluentContentSchemaProvider(SchemaRegistryClient schemaRegistryClient)
     {
         this.schemaRegistryClient = requireNonNull(schemaRegistryClient, "schemaRegistryClient is null");
     }

plugin/trino-kafka/src/main/java/io/trino/plugin/kafka/schema/confluent/ConfluentModule.java

@@ -94,7 +94,7 @@ protected void setup(Binder binder)
         configBinder(binder).bindConfig(ConfluentSchemaRegistryConfig.class);
         install(new ConfluentDecoderModule());
         install(new ConfluentEncoderModule());
-        binder.bind(ContentSchemaProvider.class).to(AvroConfluentContentSchemaProvider.class).in(Scopes.SINGLETON);
+        binder.bind(ContentSchemaProvider.class).to(ConfluentContentSchemaProvider.class).in(Scopes.SINGLETON);
         newSetBinder(binder, SchemaRegistryClientPropertiesProvider.class);
         newSetBinder(binder, SchemaProvider.class).addBinding().to(AvroSchemaProvider.class).in(Scopes.SINGLETON);
         // Each SchemaRegistry object should have a new instance of SchemaProvider

plugin/trino-kafka/src/test/java/io/trino/plugin/kafka/schema/confluent/TestAvroConfluentContentSchemaProvider.java renamed to plugin/trino-kafka/src/test/java/io/trino/plugin/kafka/schema/confluent/TestConfluentContentSchemaProvider.java

@@ -32,7 +32,7 @@
 import static org.assertj.core.api.Assertions.assertThat;
 import static org.assertj.core.api.Assertions.assertThatThrownBy;
 
-public class TestAvroConfluentContentSchemaProvider
+public class TestConfluentContentSchemaProvider
 {
     private static final String TOPIC = "test";
     private static final String SUBJECT_NAME = format("%s-value", TOPIC);
@@ -44,7 +44,7 @@ public void testAvroConfluentSchemaProvider()
         MockSchemaRegistryClient mockSchemaRegistryClient = new MockSchemaRegistryClient();
         AvroSchema schema = getAvroSchema();
         mockSchemaRegistryClient.register(SUBJECT_NAME, schema);
-        AvroConfluentContentSchemaProvider avroConfluentSchemaProvider = new AvroConfluentContentSchemaProvider(mockSchemaRegistryClient);
+        ConfluentContentSchemaProvider avroConfluentSchemaProvider = new ConfluentContentSchemaProvider(mockSchemaRegistryClient);
         KafkaTableHandle tableHandle = new KafkaTableHandle("default", TOPIC, TOPIC, AvroRowDecoderFactory.NAME, AvroRowDecoderFactory.NAME, Optional.empty(), Optional.empty(), Optional.empty(), Optional.of(SUBJECT_NAME), ImmutableList.of(), TupleDomain.all());
         assertThat(avroConfluentSchemaProvider.getMessage(tableHandle)).isEqualTo(Optional.of(schema).map(AvroSchema::toString));
         assertThat(avroConfluentSchemaProvider.getKey(tableHandle)).isEqualTo(Optional.empty());
@@ -64,7 +64,7 @@ public void testAvroSchemaWithReferences()
                 .orElseThrow();
         mockSchemaRegistryClient.register(SUBJECT_NAME, schemaWithReference);
 
-        AvroConfluentContentSchemaProvider avroConfluentSchemaProvider = new AvroConfluentContentSchemaProvider(mockSchemaRegistryClient);
+        ConfluentContentSchemaProvider avroConfluentSchemaProvider = new ConfluentContentSchemaProvider(mockSchemaRegistryClient);
         assertThat(avroConfluentSchemaProvider.readSchema(Optional.empty(), Optional.of(SUBJECT_NAME)).map(schema -> new Parser().parse(schema))).isPresent();
     }