From 4fbc29c98a2a62863102c1c2088937474baf2a65 Mon Sep 17 00:00:00 2001 From: Blie Arkansol Date: Tue, 19 Aug 2014 10:52:46 +0800 Subject: [PATCH] undo unnecessary change --- .../org/apache/spark/graphx/VertexRDDSuite.scala | 14 -------------- 1 file changed, 14 deletions(-) diff --git a/graphx/src/test/scala/org/apache/spark/graphx/VertexRDDSuite.scala b/graphx/src/test/scala/org/apache/spark/graphx/VertexRDDSuite.scala index 39e62ea8edd9f..cc86bafd2d644 100644 --- a/graphx/src/test/scala/org/apache/spark/graphx/VertexRDDSuite.scala +++ b/graphx/src/test/scala/org/apache/spark/graphx/VertexRDDSuite.scala @@ -29,10 +29,6 @@ class VertexRDDSuite extends FunSuite with LocalSparkContext { VertexRDD(sc.parallelize((0 to n).map(x => (x.toLong, x)), 5)) } - def verticesDup(sc: SparkContext, n: Int) = { - VertexRDD(sc.parallelize((-n to n).map(x => (math.abs(x.toLong), x)), 5) - } - test("filter") { withSpark { sc => val n = 100 @@ -103,14 +99,4 @@ class VertexRDDSuite extends FunSuite with LocalSparkContext { } } - // TODO: - // need edges in apply function - test("apply.mergeFunc") { - withSpark { sc => - val n = 100 - val verts = vertices(sc, n) - val evens = verts.filter(q => ((q._2 % 2) == 0)) - assert(evens.count === (0 to n).filter(_ % 2 == 0).size) - } - } }