diff options
author | Ankur Dave <ankurdave@gmail.com> | 2014-01-13 16:15:10 -0800 |
---|---|---|
committer | Ankur Dave <ankurdave@gmail.com> | 2014-01-13 17:03:03 -0800 |
commit | 1bd5cefcae2769d48ad5ef4b8197193371c754da (patch) | |
tree | 8248ab428af3a76b89f4cfbe526a839a31284d81 /graphx/src/test/scala/org | |
parent | e2d25d2dfeb1d43d1e36f169250d8efef4ac232a (diff) | |
download | spark-1bd5cefcae2769d48ad5ef4b8197193371c754da.tar.gz spark-1bd5cefcae2769d48ad5ef4b8197193371c754da.tar.bz2 spark-1bd5cefcae2769d48ad5ef4b8197193371c754da.zip |
Remove aggregateNeighbors
Diffstat (limited to 'graphx/src/test/scala/org')
-rw-r--r-- | graphx/src/test/scala/org/apache/spark/graphx/GraphOpsSuite.scala | 26 |
1 files changed, 0 insertions, 26 deletions
diff --git a/graphx/src/test/scala/org/apache/spark/graphx/GraphOpsSuite.scala b/graphx/src/test/scala/org/apache/spark/graphx/GraphOpsSuite.scala index cd3c0bbd30..7a901409d5 100644 --- a/graphx/src/test/scala/org/apache/spark/graphx/GraphOpsSuite.scala +++ b/graphx/src/test/scala/org/apache/spark/graphx/GraphOpsSuite.scala @@ -8,32 +8,6 @@ import org.scalatest.FunSuite class GraphOpsSuite extends FunSuite with LocalSparkContext { - test("aggregateNeighbors") { - withSpark { sc => - val n = 3 - val star = - Graph.fromEdgeTuples(sc.parallelize((1 to n).map(x => (0: VertexID, x: VertexID))), 1) - - val indegrees = star.aggregateNeighbors( - (vid, edge) => Some(1), - (a: Int, b: Int) => a + b, - EdgeDirection.In) - assert(indegrees.collect().toSet === (1 to n).map(x => (x, 1)).toSet) - - val outdegrees = star.aggregateNeighbors( - (vid, edge) => Some(1), - (a: Int, b: Int) => a + b, - EdgeDirection.Out) - assert(outdegrees.collect().toSet === Set((0, n))) - - val noVertexValues = star.aggregateNeighbors[Int]( - (vid: VertexID, edge: EdgeTriplet[Int, Int]) => None, - (a: Int, b: Int) => throw new Exception("reduceFunc called unexpectedly"), - EdgeDirection.In) - assert(noVertexValues.collect().toSet === Set.empty[(VertexID, Int)]) - } - } - test("joinVertices") { withSpark { sc => val vertices = |