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
方法。
我刚刚将 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
方法。