Skip to content
This repository was archived by the owner on Jan 9, 2020. It is now read-only.

Commit 66cb72d

Browse files
zhengruifengyanboliang
authored andcommitted
[MINOR][DOC] Add missing call of update() in examples of PeriodicGraphCheckpointer & PeriodicRDDCheckpointer
## What changes were proposed in this pull request? forgot to call `update()` with `graph1` & `rdd1` in examples for `PeriodicGraphCheckpointer` & `PeriodicRDDCheckpoin` ## How was this patch tested? existing tests Author: Zheng RuiFeng <[email protected]> Closes apache#19198 from zhengruifeng/fix_doc_checkpointer.
1 parent 8d8641f commit 66cb72d

File tree

2 files changed

+2
-0
lines changed

2 files changed

+2
-0
lines changed

core/src/main/scala/org/apache/spark/rdd/util/PeriodicRDDCheckpointer.scala

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -50,6 +50,7 @@ import org.apache.spark.util.PeriodicCheckpointer
5050
* {{{
5151
* val (rdd1, rdd2, rdd3, ...) = ...
5252
* val cp = new PeriodicRDDCheckpointer(2, sc)
53+
* cp.update(rdd1)
5354
* rdd1.count();
5455
* // persisted: rdd1
5556
* cp.update(rdd2)

graphx/src/main/scala/org/apache/spark/graphx/util/PeriodicGraphCheckpointer.scala

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -50,6 +50,7 @@ import org.apache.spark.util.PeriodicCheckpointer
5050
* {{{
5151
* val (graph1, graph2, graph3, ...) = ...
5252
* val cp = new PeriodicGraphCheckpointer(2, sc)
53+
* cp.updateGraph(graph1)
5354
* graph1.vertices.count(); graph1.edges.count()
5455
* // persisted: graph1
5556
* cp.updateGraph(graph2)

0 commit comments

Comments
 (0)