您可以尝试创建一个函数，该函数接受要按顺序转换的列，并将其更改为list
val selectcolumns=df.columns.toseq

column_to_list(DF,selectColumns)
def column_to_list(inputdf:DataFrame,col_names:Seq[String])  =
  {
    col_names.map(colName => {
      val col_to_list = inputdf.select(colName).collectAsList()
      println(col_to_list)
    })
  }

检查以下代码。
假设 col1 & col2 属于 string .

val list = table.select(
    collect_set($"col1").as("col1"),
    collect_set($"col2").as("col2")
)
.map(c => (c.getAs[Seq[String]](0),c.getAs[Seq[String]](1)))
.collect
val list1 = list.head
val list2 = list.tail

希望表中的数据少一点，试试这个-

val table = spark.sql("select name, age from values ('bob', 1), ('sam', 2), ('bob', 1) T(name,age)")
    table.show(false)
    table.printSchema()
    /**
      * +----+---+
      * |name|age|
      * +----+---+
      * |bob |1  |
      * |sam |2  |
      * |bob |1  |
      * +----+---+
      *
      * root
      * |-- name: string (nullable = false)
      * |-- age: integer (nullable = false)
      */
    val rowArray = table.select($"name", $"age").collect()
    val nameList = rowArray.map(_(0)).toList.distinct
    val ageList = rowArray.map(_(1)).toList.distinct
    println(nameList.mkString(", "))
    println(ageList.mkString(", "))
    /**
      * bob, sam
      * 1, 2
      */
    val row = table.select(
      collect_set($"name").as("name"),
      collect_set($"age").as("age")
    ).head
    val nameSet = row.getAs[Seq[String]]("name")
    val ageSet = row.getAs[Seq[Int]]("age")
    println(nameSet.mkString(", "))
    println(ageSet.mkString(", "))
    /**
      * bob, sam
      * 1, 2
      */