Apache Spark 2.x Cookbook

How to do it...

1. Import the graphx related classes:

        scala> import org.apache.spark.graphx._scala> import org.apache.spark.rdd.RDD

2. Load the vertex data in an array:

        scala> val vertices = Array((1L, ("Santa Clara","CA")),(2L,           ("Fremont","CA")),(3L, ("San Francisco","CA")))

3. Load the array of vertices into the RDD of vertices:

        scala> val vrdd = sc.parallelize(vertices)

4. Load the edge data in an array:

        scala> val edges = Array(Edge(1L,2L,20),Edge(2L,3L,44)          ,Edge(3L,1L,53))

5. Load the data into the RDD of edges:

        scala> val erdd = sc.parallelize(edges)

6. Create the graph:

        scala> val graph = Graph(vrdd,erdd)

7. Print all the vertices of the graph:

        scala> graph.vertices.collect.foreach(println)

8. Print all the edges of the graph: ...