File tree Expand file tree Collapse file tree 1 file changed +0
-14
lines changed
graphx/src/test/scala/org/apache/spark/graphx Expand file tree Collapse file tree 1 file changed +0
-14
lines changed Original file line number Diff line number Diff line change @@ -29,10 +29,6 @@ class VertexRDDSuite extends FunSuite with LocalSparkContext {
2929 VertexRDD (sc.parallelize((0 to n).map(x => (x.toLong, x)), 5 ))
3030 }
3131
32- def verticesDup (sc : SparkContext , n : Int ) = {
33- VertexRDD (sc.parallelize((- n to n).map(x => (math.abs(x.toLong), x)), 5 )
34- }
35-
3632 test(" filter" ) {
3733 withSpark { sc =>
3834 val n = 100
@@ -103,14 +99,4 @@ class VertexRDDSuite extends FunSuite with LocalSparkContext {
10399 }
104100 }
105101
106- // TODO:
107- // need edges in apply function
108- test(" apply.mergeFunc" ) {
109- withSpark { sc =>
110- val n = 100
111- val verts = vertices(sc, n)
112- val evens = verts.filter(q => ((q._2 % 2 ) == 0 ))
113- assert(evens.count === (0 to n).filter(_ % 2 == 0 ).size)
114- }
115- }
116102}
You can’t perform that action at this time.
0 commit comments