Как использовать GraphX ​​с Spark Streaming? - PullRequest
0 голосов
/ 14 мая 2018

У меня есть приложение Spark Structured Streaming, которое получает сообщения Kafka.Для каждого такого сообщения он извлекает исходные данные из БД и выполняет расчеты.Я хочу использовать GraphX ​​(или GraphFrame) для построения графика для каждого сообщения и выполнения расчетов.Я понимаю, как сделать это с помощью простого пакетного задания, но как использовать GraphX ​​с Spark Streaming?

...