Как преобразовать DStream[(Строка, строка)] в DStream[(Строка, массив[Строка])]

#scala #spark-streaming #twitter-streaming-api

Вопрос:

Я читаю сообщение в Твиттере. Я беру язык и пишу текст в твиттере, так что это (Строка, строка) Но я хочу разделить текст Твиттера пробелом, чтобы он представлял собой массив слов. Тогда это будет строка, массив[Строка]). Мой код таков:

 val statusesLangText = tweets.map(status =gt; (status.getLang, status.getText))   val tweetWordsLang = statusesLangText.flatMap((x, y) =gt; (x, y.split(" ")))  

Но это дает мне:

Не удается разрешить разделение символов

Кто-нибудь знает, как я могу этого достичь?

Комментарии:

1. val tweetWordsLang = statusesLangText.map{ case (x, y) =gt; (x, y.split(" "))}