如何用spark中的其他值替换数组中的项？

yfwxisqw 于 2021-05-16 发布在 Spark

关注(0)|答案(1)|浏览(598)

+--------------------------------+
|Subject                         |
+--------------------------------+
|[English, Math, Science, Spark] |
+--------------------------------+
|[English, History, Art]         |
+--------------------------------+

我们如何用两排的英语来代替英语？

apache-spark replace Arrays capitalization

来源：https://stackoverflow.com/questions/65240032/how-to-replace-item-in-array-with-other-values-in-spark

1条答案

按热度按时间

mzillmmw1#

使用自定义自定义项替换单词：

val replace = udf{ x: Seq[String] => x.map(y => if(y == "English") "ENGLISH" else y) }

val df2 = df.select(replace($"Subject").alias("Subject"))

df2.show(false)
+-------------------------------+
|Subject                        |
+-------------------------------+
|[ENGLISH, Math, Science, Spark]|
|[ENGLISH, History, Art]        |
+-------------------------------+

赞(0）回复(0）举报 2021-05-16

我来回答

如何用spark中的其他值替换数组中的项？

1条答案

相关问题

热门标签

最新问答