aboutsummaryrefslogtreecommitdiff
path: root/sql/core/src/test/java
diff options
context:
space:
mode:
authorReynold Xin <rxin@databricks.com>2016-03-15 14:57:54 -0700
committerYin Huai <yhuai@databricks.com>2016-03-15 14:57:54 -0700
commit643649dcbfabc5d6952c2ecfb98286324c887665 (patch)
tree571751a4a87ba11fbd0e5a5c582987a2ca53b887 /sql/core/src/test/java
parent41eaabf5935052fc69f1657368fa17529d18f84b (diff)
downloadspark-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.java8
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