Как создать график (graphX), используя indexedRDD для больших наборов данных? - PullRequest
Новая
       22

Как создать график (graphX), используя indexedRDD для больших наборов данных?

0 голосов
/ 23 апреля 2019

Я пытаюсь использовать indexedRDD для графа (graphx), но я не смог найти никакого способа, потому что я пробовал много способов, но я не мог использовать его для Edges.

У меня есть sourceRDD, и я создаю еще один RDD для ребер, используя IndexedRDD, как показано ниже, но это дает ошибку времени компиляции:

Несоответствие типов, ожидаемое: RDD [(NotInferedK, NotInferedV)], фактическое: РДД [Край [String]] 

val edgeRdd: IndexedRDD[Edge[Int]] = IndexedRDD(sourceRdd.filter(line => line.toUpperCase.contains("E")).map(line => {
      val data = line.split(" ")
      Edge(data(1).toLong, data(2).toInt, data(3))
    }))
...