Spark 3.3.0 compatibility

Tom-Newton · Jan 18, 2024 · 4a49b7b · 4a49b7b
1 parent 6d59872
commit 4a49b7b
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/scala/src/main/scala/EarlyStopSortMerge.scala b/scala/src/main/scala/EarlyStopSortMerge.scala
@@ -103,7 +103,7 @@ object EarlyStopSortMerge {
     new DataFrame(
       left.sparkSession,
       logicalPlan,
-      ExpressionEncoder(logicalPlan.schema)
+      RowEncoder(logicalPlan.schema)
     )
   }
 }