Я хочу отфильтровать текстовый файл формы чтения строк с набором ключевых слов - PullRequest
0 голосов
/ 15 октября 2019

Я написал код ниже, он работает для одного слова, но когда я даю переменную seq, я не получаю вывод, может кто-нибудь сказать мне, как решить эту проблему.

val term = List("Achieving","Making")

val sc = new SparkContext("local[*]","Filter_lines")

val Lines = sc.textFile("../book.txt")

val filter_Lines = Lines.filter(l => l.contains("Making")).collect()

filter_Lines.foreach(println)

1 Ответ

0 голосов
/ 15 октября 2019

Попробуйте это -

Lines.filter(l => term.exists(t => l.contains(t))).foreach(println)

функция существует в коллекции и принимает функцию, которая возвращает true, если "l" содержит какой-либо из терминов "t".

Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...