我认为 TwitterPopTags Scala Spark 无法访问 Oauth 信息

TwitterPopTags Scala Spark not able to access Oauth information I think

我一直在尝试使用 Scala、Spark 和 intellij IDEA 对一些信息进行静态拉取,而且我已经 运行 陷入此错误已有一段时间了。我已经添加了流媒体依赖项和所有必需的 jar 文件,但是我一直收到此错误。

我花了一些时间研究这些变量,尝试手动输入我的 oauth 信息(我相信这是导致此错误的原因)并且我尝试在我的 spark 根目录中创建一个 twitter4j.properties 文件,项目根目录,甚至我的项目源文件根目录。

Usage: TwitterPopularTags <consumer key> <consumer secret> <access token> <access token secret> [<filters>]

Process finished with exit code 1

这是我不断遇到的错误。附上截图。 此外,一旦我开始工作 (oauth),我如何修改我从 Twitter 中提取的信息并可能使用本地 SQL 数据库甚至 csv 文件存储它?

谢谢![错误][1]

TwitterPopularTags 的源代码:https://github.com/apache/spark/blob/master/examples/src/main/scala/org/apache/spark/examples/streaming/TwitterPopularTags.scala

http://imgur.com/sEEiIiT

对于任何试图解决这个问题的人,您可以执行以下操作来为示例提供给您的数组提供参数,并期望您的 oauth 信息位于: 执行以下操作:

1) 编辑您的配置(单击配置下拉菜单和 select“编辑配置”。

2) 在“配置”选项卡下,您将看到“程序参数”字段

3) 在此程序参数字段中,输入代码要求的四个参数,以空格分隔。