From e93fa19007a0a78ef796455f6819eb51a1d7aa0f Mon Sep 17 00:00:00 2001 From: Daniil Pozdnyakov Date: Sun, 11 Aug 2024 22:23:16 +0300 Subject: [PATCH] Fix Scala ArrayBuffer cast to Spark ArrayData for Scala 2.13 --- .../com/databricks/spark/xml/parsers/StaxXmlParser.scala | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/src/main/scala/com/databricks/spark/xml/parsers/StaxXmlParser.scala b/src/main/scala/com/databricks/spark/xml/parsers/StaxXmlParser.scala index 36115e56..82013148 100644 --- a/src/main/scala/com/databricks/spark/xml/parsers/StaxXmlParser.scala +++ b/src/main/scala/com/databricks/spark/xml/parsers/StaxXmlParser.scala @@ -320,8 +320,8 @@ private[xml] object StaxXmlParser extends Serializable { case ArrayType(dt: DataType, _) => val values = Option(row(index)) - .map(_.asInstanceOf[ArrayBuffer[Any]]) - .getOrElse(ArrayBuffer.empty[Any]) + .map(_.asInstanceOf[Array[Any]]) + .getOrElse(Array.empty[Any]) val newValue = dt match { case st: StructType => convertObjectWithAttributes(parser, st, options, attributes) @@ -345,8 +345,8 @@ private[xml] object StaxXmlParser extends Serializable { row(anyIndex) = newValue case ArrayType(StringType, _) => val values = Option(row(anyIndex)) - .map(_.asInstanceOf[ArrayBuffer[String]]) - .getOrElse(ArrayBuffer.empty[String]) + .map(_.asInstanceOf[Array[String]]) + .getOrElse(Array.empty[String]) row(anyIndex) = values :+ newValue } } else {