apache-spark - 在 Mobius 中将 RDD 转换为 Dataset/DataFrame

Question

有没有一种简单的方法可以将 RDD 转换为 Mobius 中的数据集（或 DataFrame）。基本上类似于 scala 提供的功能

import sqlContext.implicits._

我知道有 sqlContext.CreateDataFrame() 但据我所知，这需要我定义自己的 StructType 才能进行转换。

Answer 1

不，目前，sqlContext.CreateDataFrame是唯一的选择。如果您认为 RDD 需要 ToDF()，请随时在 Mobius 存储库中创建一个问题以开始讨论。