diff options
| author | Sean Owen <sowen@cloudera.com> | 2016-04-23 10:47:50 -0700 |
|---|---|---|
| committer | Reynold Xin <rxin@databricks.com> | 2016-04-23 10:47:50 -0700 |
| commit | be0d5d3bbebf0912c27bf41ce27b5ba214e61e19 (patch) | |
| tree | 3d067a6e3aeb441217475e8fabcb4d6131575e61 /core/src/test/java | |
| parent | a55fbe2a16aa0866ff8aca25bf9f772e6eb516a1 (diff) | |
| download | spark-be0d5d3bbebf0912c27bf41ce27b5ba214e61e19.tar.gz spark-be0d5d3bbebf0912c27bf41ce27b5ba214e61e19.tar.bz2 spark-be0d5d3bbebf0912c27bf41ce27b5ba214e61e19.zip | |
[SPARK-14873][CORE] Java sampleByKey methods take ju.Map but with Scala Double values; results in type Object
## What changes were proposed in this pull request?
Java `sampleByKey` methods should accept `Map` with `java.lang.Double` values
## How was this patch tested?
Existing (updated) Jenkins tests
Author: Sean Owen <sowen@cloudera.com>
Closes #12637 from srowen/SPARK-14873.
Diffstat (limited to 'core/src/test/java')
| -rw-r--r-- | core/src/test/java/org/apache/spark/JavaAPISuite.java | 5 |
1 files changed, 2 insertions, 3 deletions
diff --git a/core/src/test/java/org/apache/spark/JavaAPISuite.java b/core/src/test/java/org/apache/spark/JavaAPISuite.java index 0f65554516..04f92d6016 100644 --- a/core/src/test/java/org/apache/spark/JavaAPISuite.java +++ b/core/src/test/java/org/apache/spark/JavaAPISuite.java @@ -44,7 +44,6 @@ import com.google.common.collect.ImmutableMap; import com.google.common.collect.Iterables; import com.google.common.collect.Iterators; import com.google.common.collect.Lists; -import com.google.common.collect.Maps; import com.google.common.base.Throwables; import com.google.common.io.Files; import org.apache.hadoop.io.IntWritable; @@ -1644,7 +1643,7 @@ public class JavaAPISuite implements Serializable { return new Tuple2<>(i % 2, 1); } }); - Map<Integer, Object> fractions = Maps.newHashMap(); + Map<Integer, Double> fractions = new HashMap<>(); fractions.put(0, 0.5); fractions.put(1, 1.0); JavaPairRDD<Integer, Integer> wr = rdd2.sampleByKey(true, fractions, 1L); @@ -1670,7 +1669,7 @@ public class JavaAPISuite implements Serializable { return new Tuple2<>(i % 2, 1); } }); - Map<Integer, Object> fractions = Maps.newHashMap(); + Map<Integer, Double> fractions = new HashMap<>(); fractions.put(0, 0.5); fractions.put(1, 1.0); JavaPairRDD<Integer, Integer> wrExact = rdd2.sampleByKeyExact(true, fractions, 1L); |