java - Spark : How to convert from Dataset[String] back to good and old Dataframe

Question

我有一些使用Dataframe的遗留代码，但现在它需要处理Dataset[String]。目前，我必须使其工作，因此我正在寻找一种快速且简单的方法来从 Dataset[String] 转换为 Dataframe，以便我的方法可以对其进行处理。任何具有 Spark 知识的人都可以提供帮助吗？

Answer 1

正如 Alberto Bonsanto 在评论中所说，您可以使用 toDF 方法:

import sqlContext.implicits._
val ds = Seq("a", "b").toDS
val df = ds.toDF