On Tue, Oct 14, 2014 at 1:57 PM, Duy Huynh <[email protected]> wrote:
> a related question, what is the best way to update the values of existing
> vertices and edges?
>
Many of the Graph methods deal with updating the existing values in bulk,
including mapVertices, mapEdges, mapTriplets, mapReduceTriplets, and
outerJoinVertices.
To update just a small number of existing values, IndexedRDD would be
ideal, but until it makes it into GraphX the best way is to use one of the
above methods. This will be slower since it's touching all of the vertices,
but it will achieve the same goal.
For example, if you had a graph and wanted to update the value of vertex 1
to "a", you could do the following:
val graph = ...
val updates = sc.parallelize(List((1L, "a")))
val newGraph = graph.outerJoinVertices(updates) { (id, a, b) => b }
Ankur <http://www.ankurdave.com/>
