首页 > 解决方案 > Spark Scala 中嵌套模式的字符串函数

问题描述

我正在使用 Scala 编程语言学习 Spark。

输入文件 -> "个人":{"ID":3424,"Name":["abcs","dakjdb"]}}

架构 ->

root
  |-- Personal: struct (nullable = true)
  |    |-- ID: integer (nullable = true)
  |    |-- Name: array (nullable = true)
  |    |    |-- element: string (containsNull = true)

输出操作 -> 我想连接“名称”元素的字符串 例如 - abcs|dakjdb

我正在使用数据框 API 读取文件。请帮助我。

标签: scalaapache-spark

解决方案


有一个内置函数concat_ws在这里应该很有用。


推荐阅读