Spark Dataframe(Scala)以在StructType [duplicate]中串联数组(作为StructField)>> [

问题描述 投票:0回答:1
scala apache-spark
1个回答
0
投票
val explodedOnceDF = df.select(col("customer_id"),explode("service").as("service")) val explodedTwiceDF = explodedOnceDF.select(col("customer_id"),explode("service").as("service")) val requiredOutput = explodedTwiceDF.groupBy("customer_id").agg(collect_list("service").as("service")).select(col("customer_id"),col("service"))
© www.soinside.com 2019 - 2024. All rights reserved.