Обжигающие работают на группу после groupBy
Я пишу ошпаривающую работу.
Вот что я хочу сделать: первая группа по ключу. Это должно дать мне кучу пар (Key, Iterator[Value]) для каждого ключа (поправьте меня, если я здесь не прав). Затем для каждой лей я хочу применить функцию к связанному с ней итератору [Value].
Как мне это сделать? В настоящее время я использую groupBy, а затем mapGroup. Я получаю Iterator [Value], но этот итератор по какой-то причине имеет только одно значение. mapGroup не может работать с несколькими значениями. Важно, чтобы я видел все значения для любого данного ключа одновременно. Есть идеи?
Спасибо!