我用下面的代码带来了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")
暂无答案!
目前还没有任何答案,快来回答吧!