Я новичок в свечах и scala, я пытаюсь
У меня есть СДР в форме (презентация, CompactBuffer (3, 3, 24, 24, 24, 24, 24, 28) , 28, 28)) Я пытаюсь преобразовать в (представление, список ((3,2), (24,5), (28,3))
Я могу преобразовать в форму ( string, Iterable [String]) (представление, список ((3,1), (3,1), (24,1), (24,1), (24,1), (24,1), (24) , 1), (28,1), (28,1), (28,1))).
Как сгруппировать их в (3,2), (24, 3)
''' val RDD4 = RDD3.map {
case (key, values) =>
val v = values.map(word => (word, 1))
(key, v)
}'''