Return the old RowEncoder API

joomcode · Nov 29, 2023 · a862a46 · a862a46
1 parent 853c926
commit a862a46
Showing 1 changed file with 8 additions and 0 deletions.
diff --git a/sql/api/src/main/scala/org/apache/spark/sql/catalyst/encoders/RowEncoder.scala b/sql/api/src/main/scala/org/apache/spark/sql/catalyst/encoders/RowEncoder.scala
@@ -59,6 +59,14 @@ import org.apache.spark.sql.types._
  * }}}
  */
 object RowEncoder {
+  def apply(schema: StructType, lenient: Boolean): ExpressionEncoder[Row] = {
+    ExpressionEncoder(schema, lenient)
+  }
+
+  def apply(schema: StructType): ExpressionEncoder[Row] = {
+    ExpressionEncoder(schema)
+  }
+
   def encoderFor(schema: StructType): AgnosticEncoder[Row] = {
     encoderFor(schema, lenient = false)
   }