Spark GraphX in Action

List of Listings

Chapter 3. Some fundamentals

Listing 3.1. helloworld.sbt

Listing 3.2. hellworld.scala

Chapter 4. GraphX Basics

Listing 4.1. Construct a graph as shown in figure 4.3

Listing 4.2. Retrieve the edges from the just-constructed graph

Listing 4.3. Get a triplet(s) version of the graph data

Listing 4.4. Add Boolean annotation to edges indicating a condition

Listing 4.5. Using aggregateMessages[]() to compute the out-degree of each vertex

Listing 4.6. RDD join() to match up VertexIds with vertex data

Listing 4.7. map() and swap() to clean up output

Listing 4.8. rightOuterJoin() instead of join() to pull in “forgotten” vertices

Listing 4.9. Option[]’s getOrElse() to clean up rightOuterJoin() output

Listing 4.10. Iterated (via recursion) ...