1

我刚刚从http://zeppelin-project.org/docs/tutorial/tutorial.html（“流数据教程”部分）将示例项目添加到我的 Zeppelin Notebook 中。当我运行应用程序时，我得到了异常：

<console>:67: error: value registerTempTable is not a member of org.apache.spark.rdd.RDD[Tweet]
            rdd.registerTempTable("tweets")

它也不适用于该方法的使用

rdd.registerAsTable("tweets")
4

1 回答 1

2

因为您需要将 RDD 转换为 DataFrame 才能应用该registerTempTable方法。

于 2015-12-15T16:37:13.490 回答