使用Spark中的Scala對文件中的引號數進行計數

Question

我使用Spark和Scala作爲語言。我正在嘗試讀取文件並計算其中的空格和引號的數量。我得到正確的輸出空間，但不正確的文件中的引號數量。表達是否正確？

val file = sc.textFile("file:///Users/Desktop/test/employee.txt") 
1) val space = file.filter(line => line.contains(" ")).count() --O/P = 2 
2) val counter = file.filter(line => line.contains('"')).count() - Wrong Output 

     File : 
    "abc","def","xyc","asas", "esd" 
     "343","32","234","11", "RE" 

Answer 1

看起來兩個表達式都不正確。如果我找對了，你想要所有的空格和引號，但是你的代碼會計算有空格/引號的行數。

還有一個問題：使用 '\ 「' 代替'」

修復：

val space = file.map(line => line.count(_==' ')).sum() 
val counter = file.map(line => line.count(_=='\"')).sum()