Scala чтение из файла CSV - PullRequest
0 голосов
/ 04 мая 2020

Я пытаюсь прочитать столбец из CSV-файла. Проблема, которую я получаю, заключается в том, что «

org.apache.spark.sql.catalyst.parser.ParseException: 
mismatched input ''s'' expecting <EOF>(line 1, pos 18)

Данные в столбце записаны так:« »« Dental by Design »» «

Так что, когда я пытаюсь прочитать из В столбце я получаю сообщение об ошибке выше. Мой код:

val businessName = business.filter("name == 'mcdonald's'")

1 Ответ

0 голосов
/ 04 мая 2020

Попробуйте код ниже.

scala> val business = Seq(("mcdonald's"),("srinivas"),("ravi")).toDF("name")
business: org.apache.spark.sql.DataFrame = [name: string]

scala> business.filter($"name" === """mcdonald's""").show
+----------+
|      name|
+----------+
|mcdonald's|
+----------+

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