val schema = StructType( Seq( StructField("app", StringType, nullable = true), StructField("server", StringType, nullable = true), StructField("file", StringType, nullable = true), StructField("...", StringType, nullable = true) ) ) val row = ... val dataset = session.createDataFrame(row, schema)
How can i split dataset to dataset array by composite key(app, server,file) as follow map<app, server,file=>dataset> Thanks.