使用 map 函数转换类型的列 map &收集数据。检查以下代码。

scala> df.show(false)
+---+------+
|key|value |
+---+------+
|11 |100212|
|12 |122371|
|13 |235637|
|14 |54923 |
|15 |9785  |
|16 |5217  |
+---+------+
scala> df
.select(map(df.columns.map(col):_*).as("map"))
.as[Map[String,String]]
.collect()
.reduce(_ ++ _)
res48: Map[String,String] = Map(12 -> 122371, 15 -> 9785, 11 -> 100212, 13 -> 235637, 16 -> 5217, 14 -> 54923)

df.collect().map(row => row.getAs[String](0) -> row.getAs[String](1)).toMap

你可以用 collectAsMap 方法。

val result = data.as[(String, String)].rdd.collectAsMap()
// result: Map[String, String] = Map(12 -> 122371, 15 -> 9785, 11 -> 100212, 14 -> 54923, 16 -> 5217, 13 -> 235637)

顺便说一句，记住收集所有数据到驱动程序是一个昂贵的操作，可能会导致内存不足的错误，请确保数据是小之前。