如何爆炸空间分隔的列？

Question

我在 Spark Scala 中有一个示例数据框，其中包含一列和许多其他列 50+ 并且需要分解 id：

示例数据：

id             name   address
234 435 567    auh    aus
345 123        muji   uk

输出数据：

id             name   address
234            auh    aus
435            auh    aus
567            auh    aus
345            muji   uk
123            muji   uk

Answer 1

试试这个：

import org.apache.spark.sql.functions._

scala> df.withColumn("id", explode(split($"id", " "))).show
+---+----+-------+
| id|name|address|
+---+----+-------+
|234| auh|    aus|
|435| auh|    aus|
|567| auh|    aus|
|345|muji|     uk|
|123|muji|     uk|
+---+----+-------+