aboutsummaryrefslogtreecommitdiff
path: root/sql/core/src/test/java
diff options
context:
space:
mode:
authorCheng Hao <hao.cheng@intel.com>2016-03-16 11:20:15 -0700
committerReynold Xin <rxin@databricks.com>2016-03-16 11:20:15 -0700
commitd9670f84739b0840501b19b8cb0e851850edb8c1 (patch)
treea664b7f0ca4e64b025408d770412dd8be8c07422 /sql/core/src/test/java
parentd9e8f26d0334f393e3b02d7a3b607be54a2a5efe (diff)
downloadspark-d9670f84739b0840501b19b8cb0e851850edb8c1.tar.gz
spark-d9670f84739b0840501b19b8cb0e851850edb8c1.tar.bz2
spark-d9670f84739b0840501b19b8cb0e851850edb8c1.zip
[SPARK-13894][SQL] SqlContext.range return type from DataFrame to DataSet
## What changes were proposed in this pull request? https://issues.apache.org/jira/browse/SPARK-13894 Change the return type of the `SQLContext.range` API from `DataFrame` to `Dataset`. ## How was this patch tested? No additional unit test required. Author: Cheng Hao <hao.cheng@intel.com> Closes #11730 from chenghao-intel/range.
Diffstat (limited to 'sql/core/src/test/java')
-rw-r--r--sql/core/src/test/java/test/org/apache/spark/sql/JavaDataFrameSuite.java4
1 files changed, 2 insertions, 2 deletions
diff --git a/sql/core/src/test/java/test/org/apache/spark/sql/JavaDataFrameSuite.java b/sql/core/src/test/java/test/org/apache/spark/sql/JavaDataFrameSuite.java
index 7fe17e0cf7..f3c5a86e20 100644
--- a/sql/core/src/test/java/test/org/apache/spark/sql/JavaDataFrameSuite.java
+++ b/sql/core/src/test/java/test/org/apache/spark/sql/JavaDataFrameSuite.java
@@ -328,7 +328,7 @@ public class JavaDataFrameSuite {
@Test
public void testCountMinSketch() {
- Dataset<Row> df = context.range(1000);
+ Dataset df = context.range(1000);
CountMinSketch sketch1 = df.stat().countMinSketch("id", 10, 20, 42);
Assert.assertEquals(sketch1.totalCount(), 1000);
@@ -353,7 +353,7 @@ public class JavaDataFrameSuite {
@Test
public void testBloomFilter() {
- Dataset<Row> df = context.range(1000);
+ Dataset df = context.range(1000);
BloomFilter filter1 = df.stat().bloomFilter("id", 1000, 0.03);
Assert.assertTrue(filter1.expectedFpp() - 0.03 < 1e-3);