GraphFrames: агрегировать вершины по отношению - PullRequest
Новая
       22

GraphFrames: агрегировать вершины по отношению

0 голосов
/ 17 ноября 2018

В эти выходные я пинаю шины с помощью GraphFrames, и мне нужна помощь с запросом на агрегацию.Мой GraphFrame построен с использованием данных ниже.По сути, мне нужно следовать за вершиной, используя определенные отношения, и объединять их в виде списков.Поэтому в основном мне нужно объединить свой граф в «group1»: [a, b, c, d] И «group2»: [d, e] (так как две группы не имеют общих отношений).

Из моего прочтения звучит, как AggregateMessages - инструмент для работы, но я не понимаю, как его собрать.

Вопрос 1: Как объединить узлы, поскольку они являются строковым типом.

gFrame.edges (). GroupBy ("отношение"). Сумма ("источник"). Show ();

Вопрос 2: Если я сгруппирую ребра по отношению «следовать», то получу все узлы в одной группе.Как группировать только по «связанным» вершинам.

Вот мои данные: 

Vertex:
{name: a}
{name: b}
{name: c}
{name: d}
{name: e}

Edges:
{src: a, dest: b: relation: follow}
{src: c, dest: b: relation: follow}
{src: c, dest: a: relation: follow}
{src: d, dest: e: relation: follow}

Спасибо!

...