spark twitter集成

sy5wg1nm  于 2021-05-18  发布在  Spark
关注(0)|答案(0)|浏览(280)

我用下面的代码带来了tweets,它是用来工作,直到某个时候回来,现在它没有带来任何tweets,目录只是显示“\u成功”文件,什么可能发生在这里
我没有保留一些捕获oauth细节的代码。

val ssc = new StreamingContext(sc, Seconds(1))
// Create a DStream from Twitter using our streaming context
    val tweets = TwitterUtils.createStream(ssc, None)
//you can verify that there are directories with names as tweets-* .Please stop after a while in order to prevent storage getting exhausted
tweets.saveAsTextFiles("tweets")

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题