我想在我的流式文本中找到要发送的文本。
val myTwitter = TwitterUtils.createStream(ssc, None,) val incoming = myTwitter.map(status => status.getText())
我想根据一个键来分析传入的文本。如果它存在，我会采取如果不在乎。我怎么做？谢谢。
b1zrtrql1#
不应该
val myTwitter = TwitterUtils.createStream(ssc, None,) val incoming = myTwitter.filter(status => status.getText().contains("twitter"))
工作？
1条答案
按热度按时间b1zrtrql1#
不应该
工作？