Spark Streaming: агрегирование значений по партиям - PullRequest
2 голосов
/ 28 февраля 2020

У нас есть задание Spark Streaming, которое вычисляет некоторые значения в каждом пакете. Что нам нужно сделать сейчас - это агрегировать значения по ВСЕМ партиям. Какова лучшая стратегия для этого в Spark Streaming. Должны ли мы использовать «Аккумуляторы искры» для этого?

...