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>
> .
>