我想在我的流文本中找到文本。
val myTwitter = TwitterUtils.createStream(ssc, None,)
val incoming = myTwitter.map(status => status.getText())
我想根据一个键分析传入的文本。如果它存在，如果不关心，我会采取。我该怎么做？
谢谢。
最佳答案
不应该
val myTwitter = TwitterUtils.createStream(ssc, None,)
val incoming = myTwitter.filter(status => status.getText().contains("twitter"))
工作？
关于scala - Spark Streaming 包含文本，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/33420452/