Я читаю из CSV-файла, и у меня есть столбец, в котором я хочу сосчитать каждый элемент в нем. Я пишу в scala.
def problem4(trips: RDD[Trip]): String = { val result = trips.map(x=>x.zip_code).collect()
}