scala – 从Spark读取String数组

发布时间：2020-12-16 19:19:37 所属栏目：安全来源：网络整理

导读：我将一个Array [String]保存到Spark的Parquet文件中. 为了阅读它,我使用： row.getAs[Array[String]]("result") 但得到： java.lang.ClassCastException: scala.collection.mutable.WrappedArray$ofRef cannot be cast to [Ljava.lang.String; 这是printSche

我将一个Array [String]保存到Spark的Parquet文件中.

为了阅读它,我使用：

row.getAs[Array[String]]("result")

但得到：

java.lang.ClassCastException: scala.collection.mutable.WrappedArray$ofRef cannot be cast to [Ljava.lang.String;

这是printSchema()的结果：

root                                                                            
 |-- result: array (nullable = true)
 |    |-- element: string (containsNull = true)

如何修改getAs()？

解决方法

row.getAs [Seq [String]](“result”)是否有效？

（编辑：李大同）

【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!