Apache Zeppelin 和 Spark Streaming:Twitter 示例不起作用

Apache Zeppelin & Spark Streaming: Twitter Example won't work

我刚刚将 http://zeppelin-project.org/docs/tutorial/tutorial.html 中的示例项目添加到我的 Zeppelin Notebook(部分 "Tutorial with Streaming Data")。当我 运行 应用程序时,我得到异常:

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

它也不会使用该方法

rdd.registerAsTable("tweets")

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