在 Mobius 中将 RDD 转换为 Dataset/DataFrame

Question

在 Mobius 中是否有一种简单的方法可以将 RDD 转换为 Dataset（或 DataFrame）。基本上类似于 scala

提供的功能

import sqlContext.implicits._

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

Answer 1

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