Merge remote-tracking branch 'origin/master' into ADAPT-1435

pluralsight · Aug 18, 2023 · bb37cca · bb37cca
2 parents e9230a3 + 8cf1c69
commit bb37cca
Show file tree

Hide file tree

Showing 5 changed files with 304 additions and 142 deletions.
diff --git a/avro/src/main/scala/hydra/avro/io/Operation.scala b/avro/src/main/scala/hydra/avro/io/Operation.scala
@@ -1,5 +1,6 @@
 package hydra.avro.io
 
+import org.apache.avro.Schema
 import org.apache.avro.generic.GenericRecord
 
 import scala.collection.JavaConverters._
@@ -11,3 +12,5 @@ case class Upsert(record: GenericRecord) extends Operation
 case class DeleteByKey(keys: Map[String, AnyRef]) extends Operation {
   def this(jmap: java.util.Map[String, AnyRef]) = this(jmap.asScala.toMap)
 }
+
+case class CreateOrAlterTable(schema: Schema) extends Operation
diff --git a/avro/src/main/scala/hydra/avro/registry/ConfluentSchemaRegistry.scala b/avro/src/main/scala/hydra/avro/registry/ConfluentSchemaRegistry.scala
@@ -56,7 +56,7 @@ object ConfluentSchemaRegistry extends LoggingAdapter {
       new CacheLoader[SchemaRegistryClientInfo, ConfluentSchemaRegistry] {
 
         def load(info: SchemaRegistryClientInfo): ConfluentSchemaRegistry = {
-          log.debug(s"Creating new schema registry client for ${info.url}")
+          log.debug(s"Creating new schema registry client for ${info.url}.")
           val client = if (info.url == "mock") {
             mockRegistry
           } else {