Skip to content

Commit 194a2df

Browse files
committed
Test triplet iterator in EdgePartition serialization test
1 parent e0f8ecc commit 194a2df

File tree

1 file changed

+2
-7
lines changed

1 file changed

+2
-7
lines changed

graphx/src/test/scala/org/apache/spark/graphx/impl/EdgePartitionSuite.scala

Lines changed: 2 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -103,7 +103,7 @@ class EdgePartitionSuite extends FunSuite {
103103
}
104104

105105
test("serialization") {
106-
val aList = List((0, 1, 0), (1, 0, 0), (1, 2, 0), (5, 4, 0), (5, 5, 0))
106+
val aList = List((0, 1, 1), (1, 0, 2), (1, 2, 3), (5, 4, 4), (5, 5, 5))
107107
val a: EdgePartition[Int, Int] = makeEdgePartition(aList)
108108
val javaSer = new JavaSerializer(new SparkConf())
109109
val conf = new SparkConf()
@@ -112,13 +112,8 @@ class EdgePartitionSuite extends FunSuite {
112112

113113
for (ser <- List(javaSer, kryoSer); s = ser.newInstance()) {
114114
val aSer: EdgePartition[Int, Int] = s.deserialize(s.serialize(a))
115-
assert(aSer.localSrcIds.toList === a.localSrcIds.toList)
116-
assert(aSer.localDstIds.toList === a.localDstIds.toList)
117-
assert(aSer.data.toList === a.data.toList)
115+
assert(aSer.tripletIterator().toList === a.tripletIterator().toList)
118116
assert(aSer.index != null)
119-
assert(aSer.global2local != null)
120-
assert(aSer.local2global.toList === a.local2global.toList)
121-
assert(aSer.vertexAttrs.toList === a.vertexAttrs.toList)
122117
}
123118
}
124119
}

0 commit comments

Comments
 (0)