Я отфильтровал СДР из Sale объектов, чтобы получить один Sale по идентификатору. Но как мне получить объект Sale? Я пытался сопоставить с продажи, но он также возвращает массив. А также .take(1)
Насколько я понимаю, преобразование карты просто возвращает другой RDD, и это ожидаемое поведение. Поскольку СДР является неизменной структурой данных.
val sales: RDD[Sale] = oldSales.filter(sale => sale.ID == "123-0567").map(s => s)
val filteredSale: Sale = ??