diff options
| author | Holden Karau <holden@pigscanfly.ca> | 2015-05-29 14:59:18 -0700 |
|---|---|---|
| committer | Josh Rosen <joshrosen@databricks.com> | 2015-05-29 14:59:18 -0700 |
| commit | 82a396c2f594bade276606dcd0c0545a650fb838 (patch) | |
| tree | de098342982d30d272f925bf61b291b8ee0b3f2a /core/src/test | |
| parent | 1c5b19827a091b5aba69a967600e7ca35ed3bcfd (diff) | |
| download | spark-82a396c2f594bade276606dcd0c0545a650fb838.tar.gz spark-82a396c2f594bade276606dcd0c0545a650fb838.tar.bz2 spark-82a396c2f594bade276606dcd0c0545a650fb838.zip | |
[SPARK-7910] [TINY] [JAVAAPI] expose partitioner information in javardd
Author: Holden Karau <holden@pigscanfly.ca>
Closes #6464 from holdenk/SPARK-7910-expose-partitioner-information-in-javardd and squashes the following commits:
de1e644 [Holden Karau] Fix the test to get the partitioner
bdb31cc [Holden Karau] Add Mima exclude for the new method
347ef4c [Holden Karau] Add a quick little test for the partitioner JavaAPI
f49dca9 [Holden Karau] Add partitoner information to JavaRDDLike and fix some whitespace
Diffstat (limited to 'core/src/test')
| -rw-r--r-- | core/src/test/java/org/apache/spark/JavaAPISuite.java | 2 |
1 files changed, 2 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 c2089b0e56..dfd86d3e51 100644 --- a/core/src/test/java/org/apache/spark/JavaAPISuite.java +++ b/core/src/test/java/org/apache/spark/JavaAPISuite.java @@ -212,6 +212,8 @@ public class JavaAPISuite implements Serializable { JavaPairRDD<Integer, Integer> repartitioned = rdd.repartitionAndSortWithinPartitions(partitioner); + Assert.assertTrue(repartitioned.partitioner().isPresent()); + Assert.assertEquals(repartitioned.partitioner().get(), partitioner); List<List<Tuple2<Integer, Integer>>> partitions = repartitioned.glom().collect(); Assert.assertEquals(partitions.get(0), Arrays.asList(new Tuple2<Integer, Integer>(0, 5), new Tuple2<Integer, Integer>(0, 8), new Tuple2<Integer, Integer>(2, 6))); |