diff options
author | Reynold Xin <rxin@databricks.com> | 2016-03-15 14:57:54 -0700 |
---|---|---|
committer | Yin Huai <yhuai@databricks.com> | 2016-03-15 14:57:54 -0700 |
commit | 643649dcbfabc5d6952c2ecfb98286324c887665 (patch) | |
tree | 571751a4a87ba11fbd0e5a5c582987a2ca53b887 /sql/core/src/test/java | |
parent | 41eaabf5935052fc69f1657368fa17529d18f84b (diff) | |
download | spark-643649dcbfabc5d6952c2ecfb98286324c887665.tar.gz spark-643649dcbfabc5d6952c2ecfb98286324c887665.tar.bz2 spark-643649dcbfabc5d6952c2ecfb98286324c887665.zip |
[SPARK-13895][SQL] DataFrameReader.text should return Dataset[String]
## What changes were proposed in this pull request?
This patch changes DataFrameReader.text()'s return type from DataFrame to Dataset[String].
Closes #11731.
## How was this patch tested?
Updated existing integration tests to reflect the change.
Author: Reynold Xin <rxin@databricks.com>
Closes #11739 from rxin/SPARK-13895.
Diffstat (limited to 'sql/core/src/test/java')
-rw-r--r-- | sql/core/src/test/java/test/org/apache/spark/sql/JavaDataFrameSuite.java | 8 |
1 files changed, 4 insertions, 4 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 42554720ed..7fe17e0cf7 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 @@ -316,14 +316,14 @@ public class JavaDataFrameSuite { @Test public void testTextLoad() { - Dataset<Row> df1 = context.read().text( + Dataset<String> ds1 = context.read().text( Thread.currentThread().getContextClassLoader().getResource("text-suite.txt").toString()); - Assert.assertEquals(4L, df1.count()); + Assert.assertEquals(4L, ds1.count()); - Dataset<Row> df2 = context.read().text( + Dataset<String> ds2 = context.read().text( Thread.currentThread().getContextClassLoader().getResource("text-suite.txt").toString(), Thread.currentThread().getContextClassLoader().getResource("text-suite2.txt").toString()); - Assert.assertEquals(5L, df2.count()); + Assert.assertEquals(5L, ds2.count()); } @Test |