Hi guys,

I just cherry picked Ankur's changes and added the propagateAndAggregate
primitive along with its tests. It's all on this branch (GraphPrimitives).

Best,

semih


On Tue, Jan 21, 2014 at 3:49 PM, Semih Salihoglu <semih@stanford.edu> wrote:

> Done.
>
>
> On Tue, Jan 21, 2014 at 2:59 PM, Joey <notifications@github.com> wrote:
>
>> In graphx/src/main/scala/org/apache/spark/graphx/GraphOps.scala:
>>
>> > @@ -209,6 +242,129 @@ class GraphOps[VD: ClassTag, ED: ClassTag](graph: Graph[VD, ED]) extends Seriali
>> >      graph.mask(preprocess(graph).subgraph(epred, vpred))
>> >    }
>> >
>> > + /**
>> > +   * Filters the edges of the graph by keeping only the edges that satisfy the
>> > +   * given predicate. The predicate takes as input the src and destination vertex ids and values.
>> > +   *
>> > +   * @param epred the edge predicate
>> > +   */
>> > +  def filterEdges(epred: EdgeTriplet[VD, ED] => Boolean): Graph[VD, ED] = {
>> > +    filter[VD, ED](graph => graph, epred, (vid, vval) => true)
>>
>> why not use?
>>
>> graph.subgraph(epred = epred)
>>
>> —
>> Reply to this email directly or view it on GitHub<https://github.com/apache/incubator-spark/pull/457/files#r9058689>
>> .
>>
>
>