aboutsummaryrefslogtreecommitdiff
path: root/core/src/test
diff options
context:
space:
mode:
authorOlivier Girardot <o.girardot@lateral-thoughts.com>2015-04-18 18:21:44 -0700
committerReynold Xin <rxin@databricks.com>2015-04-18 18:21:44 -0700
commit8fbd45c74e762dd6b071ea58a60f5bb649f74042 (patch)
tree25020add52beba0bee45c55f22ea203d349026c0 /core/src/test
parent729885ec6b4be61144d04821f1a6e8d2134eea00 (diff)
downloadspark-8fbd45c74e762dd6b071ea58a60f5bb649f74042.tar.gz
spark-8fbd45c74e762dd6b071ea58a60f5bb649f74042.tar.bz2
spark-8fbd45c74e762dd6b071ea58a60f5bb649f74042.zip
SPARK-6993 : Add default min, max methods for JavaDoubleRDD
The default method will use Guava's Ordering instead of java.util.Comparator.naturalOrder() because it's not available in Java 7, only in Java 8. Author: Olivier Girardot <o.girardot@lateral-thoughts.com> Closes #5571 from ogirardot/master and squashes the following commits: 7fe2e9e [Olivier Girardot] SPARK-6993 : Add default min, max methods for JavaDoubleRDD
Diffstat (limited to 'core/src/test')
-rw-r--r--core/src/test/java/org/apache/spark/JavaAPISuite.java14
1 files changed, 14 insertions, 0 deletions
diff --git a/core/src/test/java/org/apache/spark/JavaAPISuite.java b/core/src/test/java/org/apache/spark/JavaAPISuite.java
index d4b5bb5191..8a4f2a08fe 100644
--- a/core/src/test/java/org/apache/spark/JavaAPISuite.java
+++ b/core/src/test/java/org/apache/spark/JavaAPISuite.java
@@ -762,6 +762,20 @@ public class JavaAPISuite implements Serializable {
}
@Test
+ public void naturalMax() {
+ JavaDoubleRDD rdd = sc.parallelizeDoubles(Arrays.asList(1.0, 2.0, 3.0, 4.0));
+ double max = rdd.max();
+ Assert.assertTrue(4.0 == max);
+ }
+
+ @Test
+ public void naturalMin() {
+ JavaDoubleRDD rdd = sc.parallelizeDoubles(Arrays.asList(1.0, 2.0, 3.0, 4.0));
+ double max = rdd.min();
+ Assert.assertTrue(1.0 == max);
+ }
+
+ @Test
public void takeOrdered() {
JavaDoubleRDD rdd = sc.parallelizeDoubles(Arrays.asList(1.0, 2.0, 3.0, 4.0));
Assert.assertEquals(Arrays.asList(1.0, 2.0), rdd.takeOrdered(2, new DoubleComparator()));