replace if with require

mengxr · Mar 13, 2014 · a40e8fb · a40e8fb
1 parent ad483fd
commit a40e8fb
Showing 1 changed file with 2 additions and 3 deletions.
diff --git a/core/src/main/scala/org/apache/spark/rdd/RDD.scala b/core/src/main/scala/org/apache/spark/rdd/RDD.scala
@@ -310,9 +310,8 @@ abstract class RDD[T: ClassTag](
    * Return a sampled subset of this RDD.
    */
   def sample(withReplacement: Boolean, fraction: Double, seed: Int): RDD[T] = {
-    if (fraction < Double.MinValue  || fraction > Double.MaxValue) {
-      throw new Exception("Invalid fraction value:" + fraction)
-    }
+    require(fraction >= 0 && fraction <= Double.MaxValue,
+      "Invalid fraction value: " + fraction)
     if (withReplacement) {
       new PartitionwiseSampledRDD[T, T](this, new PoissonSampler[T](fraction), seed)
     } else {