Skip to content

Commit cc00767

Browse files
committed
added overrides for isCheckpointed, getCheckpointFile in EdgeRDDImpl, VertexRDDImpl. The corresponding Graph methods now work.
1 parent 188665f commit cc00767

File tree

2 files changed

+18
-2
lines changed

2 files changed

+18
-2
lines changed

graphx/src/main/scala/org/apache/spark/graphx/impl/EdgeRDDImpl.scala

Lines changed: 9 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -73,7 +73,15 @@ class EdgeRDDImpl[ED: ClassTag, VD: ClassTag] private[graphx] (
7373
override def checkpoint() = {
7474
partitionsRDD.checkpoint()
7575
}
76-
76+
77+
override def isCheckpointed: Boolean = {
78+
partitionsRDD.isCheckpointed
79+
}
80+
81+
override def getCheckpointFile: Option[String] = {
82+
partitionsRDD.getCheckpointFile
83+
}
84+
7785
/** The number of edges in the RDD. */
7886
override def count(): Long = {
7987
partitionsRDD.map(_._2.size.toLong).reduce(_ + _)

graphx/src/main/scala/org/apache/spark/graphx/impl/VertexRDDImpl.scala

Lines changed: 9 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -74,7 +74,15 @@ class VertexRDDImpl[VD] private[graphx] (
7474
override def checkpoint() = {
7575
partitionsRDD.checkpoint()
7676
}
77-
77+
78+
override def isCheckpointed: Boolean = {
79+
partitionsRDD.isCheckpointed
80+
}
81+
82+
override def getCheckpointFile: Option[String] = {
83+
partitionsRDD.getCheckpointFile
84+
}
85+
7886
/** The number of vertices in the RDD. */
7987
override def count(): Long = {
8088
partitionsRDD.map(_.size).reduce(_ + _)

0 commit comments

Comments
 (0)