reviewer comments.

Author: dorx

core/src/main/scala/org/apache/spark/api/java/JavaPairRDD.scala

@@ -158,7 +158,6 @@ class JavaPairRDD[K, V](val rdd: RDD[(K, V)])
 
   /**
    * ::Experimental::
-   *
    * Return a subset of this RDD sampled by key (via stratified sampling) containing exactly
    * math.ceil(numItems * samplingRate) for each stratum (group of pairs with the same key).
    *
@@ -176,7 +175,6 @@ class JavaPairRDD[K, V](val rdd: RDD[(K, V)])
 
   /**
    * ::Experimental::
-   *
    * Return a subset of this RDD sampled by key (via stratified sampling) containing exactly
    * math.ceil(numItems * samplingRate) for each stratum (group of pairs with the same key).
    *

core/src/main/scala/org/apache/spark/rdd/PairRDDFunctions.scala

@@ -222,7 +222,6 @@ class PairRDDFunctions[K, V](self: RDD[(K, V)])
 
   /**
    * ::Experimental::
-   *
    * Return a subset of this RDD sampled by key (via stratified sampling) containing exactly
    * math.ceil(numItems * samplingRate) for each stratum (group of pairs with the same key).
    *

core/src/test/java/org/apache/spark/JavaAPISuite.java

@@ -1246,12 +1246,12 @@ public Tuple2<Integer, Integer> call(Integer i) {
   public void sampleByKeyExact() {
     JavaRDD<Integer> rdd1 = sc.parallelize(Arrays.asList(1, 2, 3, 4, 5, 6, 7, 8), 3);
     JavaPairRDD<Integer, Integer> rdd2 = rdd1.mapToPair(
-            new PairFunction<Integer, Integer, Integer>() {
-                @Override
-                public Tuple2<Integer, Integer> call(Integer i) {
-                    return new Tuple2<Integer, Integer>(i % 2, 1);
-                }
-            });
+      new PairFunction<Integer, Integer, Integer>() {
+          @Override
+          public Tuple2<Integer, Integer> call(Integer i) {
+              return new Tuple2<Integer, Integer>(i % 2, 1);
+          }
+      });
     Map<Integer, Object> fractions = Maps.newHashMap();
     fractions.put(0, 0.5);
     fractions.put(1, 1.0);

core/src/test/scala/org/apache/spark/rdd/PairRDDFunctionsSuite.scala

@@ -592,7 +592,8 @@ class PairRDDFunctionsSuite extends FunSuite with SharedSparkContext {
       val sampleCounts = sample.countByKey()
       val takeSample = sample.collect()
       sampleCounts.foreach { case (k, v) =>
-        assert(checkSize(exact, true, expectedSampleSize(k), v, samplingRate)) }
+        assert(checkSize(exact, true, expectedSampleSize(k), v, samplingRate))
+      }
       val groupedByKey = takeSample.groupBy(_._1)
       for ((key, v) <- groupedByKey) {
         if (expectedSampleSize(key) >= 100 && samplingRate >= 0.1) {
@@ -606,7 +607,7 @@ class PairRDDFunctionsSuite extends FunSuite with SharedSparkContext {
           }
         }
       }
-      takeSample.foreach { x => assert(1 <= x._2 && x._2 <= n, s"elements not in [1, $n]") }
+      takeSample.foreach(x => assert(1 <= x._2 && x._2 <= n, s"elements not in [1, $n]"))
     }
   }