Как написать основную структуру кода в Pregel в Spark GraphX? - PullRequest
1 голос
/ 03 августа 2020

Я работаю над графиком и хочу использовать Pregel для параллельных вычислений на графике. График имеет структуру, аналогичную структуре ниже:

(1,(5,0.2))
(2,(8,0.8))
...

Ключ - это идентификатор узла, первое число в скобках - это метка узла, а второе число в скобках - оценка. Я хочу отправить атрибут каждого узла его соседям и собрать их в список. Может ли кто-нибудь помочь с написанием основной структуры кода? я имею в виду просто указание типов, которые я должен использовать внутри функций Vertexprogram, mergeprogram и sendmessage ??

...