我遵循了这个很棒的教程,除了一件事,一切都很好。
step#11,在表格中,所有的情绪分数都是0!似乎没有连接 Tone Analyzer。我确定我输入了正确的(凭据)用户名和密码。
经过一番搜索,我发现在一个月前,IBM 将 Tone Analyzer 计划从实验性更改为 Beta。
我不知道我应该在代码中更改什么,以使带有新计划的音调分析器适用于此示例?
我最近更新了教程以处理 Tone Analyzer 中的 API 更改,这些更改从实验性过渡到了 Beta。您使用的是最新版本的教程吗?
有多种原因可以解释为什么您没有收到任何推文:错误的推特或音调分析器凭据。请根据教程说明仔细检查这些。为了更好地诊断错误,我还在最新的教程版本中添加了一个 StreamingListener,它应该可以为您提供更多信息。您应该看到如下消息:
Twitter stream started
Tweets are collected real-time and analyzed
To stop the streaming and start interacting with the data use: StreamingTwitter.stopTwitterStreaming
Receiver Started: TwitterReceiver-0
Batch started with 139 records
Batch completed with 139 records
Batch started with 270 records
Stopping Twitter stream. Please wait this may take a while
Receiver Stopped: TwitterReceiver-0
Reason: : Stopped by driver
Batch completed with 270 records
Twitter stream stopped
You can now create a sqlContext and DataFrame with 38 Tweets created. Sample usage:
val (sqlContext, df) = com.ibm.cds.spark.samples.StreamingTwitter.createTwitterDataFrames(sc)
df.printSchema
sqlContext.sql("select author, text from tweets").show
最后,如果您使用的是我在 Github 上发布的预构建 jar 文件,请确保您使用的是 Spark 1.6 而不是后级版本。