Преобразование собирать строки в виде списка с группой в новый набор данных - Apache Spark - PullRequest
0 голосов
/ 30 января 2019

Я группирую свой набор данных, как показано ниже

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

DS.withColumn("combined", struct("c1","c2","c3","c4","c5"))
    .groupBy("c1").agg(collect_list("combined").as("combined_list"))

здесь я ожидаю преобразовать значение столбца комбинированный_строчный ряд в новый набор данных.Можно ли это сделать?

...