add @SInCE doc line

apache · May 11, 2021 · 5a52408 · 5a52408
1 parent 60482b3
commit 5a52408
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 1 deletion.
diff --git a/graphx/src/main/scala/org/apache/spark/graphx/lib/PageRank.scala b/graphx/src/main/scala/org/apache/spark/graphx/lib/PageRank.scala
@@ -161,6 +161,7 @@ object PageRank extends Logging {
    * @return the graph containing with each vertex containing the PageRank and each edge
    *         containing the normalized weight.
    *
+   * @since 3.2.0
    */
   def runWithOptions[VD: ClassTag, ED: ClassTag](
       graph: Graph[VD, ED], numIter: Int, resetProb: Double,
@@ -254,6 +255,8 @@ object PageRank extends Logging {
    *
    * @return the graph containing with each vertex containing the PageRank and each edge
    *         containing the normalized weight.
+   *
+   * @since 3.2.0
    */
   def runWithOptionsWithPreviousPageRank[VD: ClassTag, ED: ClassTag](
       graph: Graph[VD, ED], numIter: Int, resetProb: Double, srcId: Option[VertexId],

diff --git a/graphx/src/test/scala/org/apache/spark/graphx/lib/PageRankSuite.scala b/graphx/src/test/scala/org/apache/spark/graphx/lib/PageRankSuite.scala
@@ -261,7 +261,7 @@ class PageRankSuite extends SparkFunSuite with LocalSparkContext {
       ).vertices.collect()
 
       // assert that all scores are equal
-      assert(ranksA.zip(ranksB).forall{ case(rankA, rankB) => rankA == rankB })
+      assert(ranksA.zip(ranksB).forall { case(rankA, rankB) => rankA == rankB })
     }
   } // end of Grid PageRank with checkpoint without intermediate normalization