Spark Streaming包含文本

Question

我想在流式文本中找到文本。

val myTwitter = TwitterUtils.createStream(ssc, None,)
val incoming = myTwitter.map(status => status.getText())

我想根据关键字分析传入的文本。如果它真的存在，我会接受，如果不在乎。我该怎么做？谢谢

Answer 1

不应该

val myTwitter = TwitterUtils.createStream(ssc, None,)
val incoming = myTwitter.filter(status => status.getText().contains("twitter"))

工作？