scala - 如何将 DStream[(String, String)] 转换为 DStream[(String, Array[String])]

Question

我正在阅读 Twitter 帖子。我采用一种语言和推文文本，所以它是 (String, String) 但我想将 Twitter 文本按空格分割，以便它是一个单词数组。然后是字符串，数组[字符串]）。我的代码是：

val statusesLangText = tweets.map(status => (status.getLang, status.getText))


val tweetWordsLang = statusesLangText.flatMap((x, y) => (x, y.split(" ")))

但它给了我：

无法解决符号拆分

任何人都知道我怎样才能实现它？

标签： scalaspark-streamingtwitter-streaming-api