Abris #239 support for Spark 3.2

Author: cerveada

pom.xml

@@ -52,6 +52,7 @@
         <spark-24.version>2.4.8</spark-24.version>
         <spark-30.version>3.0.3</spark-30.version>
         <spark-31.version>3.1.2</spark-31.version>
+        <spark-32.version>3.2.0</spark-32.version>
 
 
 
@@ -364,6 +365,14 @@
                 <confluent.version>5.3.4</confluent.version>
             </properties>
         </profile>
+        <profile>
+            <id>spark-3.2</id>
+            <properties>
+                <spark.version>${spark-32.version}</spark.version>
+                <avro.version>1.10.2</avro.version>
+                <confluent.version>6.2.1</confluent.version>
+            </properties>
+        </profile>
 
         <profile>
             <id>uber</id>

src/main/scala/za/co/absa/abris/avro/sql/AvroDataToCatalyst.scala

@@ -159,4 +159,8 @@ private[abris] case class AvroDataToCatalyst(
     result = vanillaReader.read(result, decoder)
     result
   }
+
+  override protected def withNewChildInternal(newChild: Expression): Expression =
+    copy(child = newChild)
+
 }

src/main/scala/za/co/absa/abris/avro/sql/CatalystDataToAvro.scala

@@ -73,4 +73,7 @@ private[abris] case class CatalystDataToAvro(
     defineCodeGen(ctx, ev, input =>
       s"(byte[]) $expr.nullSafeEval($input)")
   }
+
+  override protected def withNewChildInternal(newChild: Expression): Expression =
+    copy(child = newChild)
 }