From a40e8fb632fb48951cace8f281cd3f30ded017e1 Mon Sep 17 00:00:00 2001
From: CodingCat <zhunansjtu@gmail.com>
Date: Thu, 13 Mar 2014 15:04:02 -0400
Subject: [PATCH] replace if with require

---
 core/src/main/scala/org/apache/spark/rdd/RDD.scala | 5 ++---
 1 file changed, 2 insertions(+), 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
index 5e7bb4531aef4..36d7f6c428987 100644
--- 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 {