spark-graphx

1зной

1ответ

Я новичок в spark-graphx и scala. Как я могу получить идентификатор вершины в графе? Это мой код: val sourceVertex=graph.vertices.filter { case (id,(_,_,_,_,_)) => id == 0} // The source vertex var c

0зной

2ответ

конструктор не может быть создан для ожидаемого типа; найдено: (T1, T2, T3, T4, T5)

Я новичок в spark-graphx и scala. Я пишу этот метод, чтобы проверить, изменился ли счет целевой вершины. def IsGoalVertexFound(graph: Graph[(VertexId,(Int,Float,Float,Float,String)),Float],goalVertex:

1зной

1ответ

Как присоединиться к искровому графику с учетом нескольких типов вершин

Я относительно новичок в искрообразовании. В основном мой график имеет: типы 2 вершинных: человек и машина край описывает, какой человек владеет какой автомобиль Я хочу данных всех человека вершин гра

1зной

1ответ

Как получить объект из aggregateMessages, а не только vertexId

package com.mypackage import org.apache.spark.graphx._ import org.apache.spark.{SparkContext, SparkConf} /** * Created by sidazhang on 11/8/16. */ case class Person(age: Int) case cl

1зной

2ответ

Общий метод в Scala GraphX

import org.apache.spark.graphx._ object Test { def main(args: Array[String]): Unit = { val graph = GraphGenerator.generate_graph() println(graph.numEdges) println(solve(graph)) }

7зной

1ответ

Реализовать направленный график как неориентированный граф с использованием GraphX

У меня есть следующий ориентированный граф, заданный узлами и ребрами ниже. Узлы 1,2,3,4,5 фронтам (1,2),(1,3),(1,4),(2,5),(3,4),(3,5),(4,5) Как преобразовать этот ориентированный граф для неориен

0зной

1ответ

Сохранение Graphx вершины на HDFS и загрузка позже

Я создаю RDD: val verticesRDD: RDD[(VertexId, Long)] = vertices я могу проверить его и все выглядит нормально: verticesRDD.take(3).foreach(println) (4000000031043205,1) (4000000031043206,2) (400000