aboutsummaryrefslogtreecommitdiff
path: root/sql
diff options
context:
space:
mode:
authorYanbo Liang <ybliang8@gmail.com>2015-12-17 09:19:46 -0800
committerReynold Xin <rxin@databricks.com>2015-12-17 09:19:46 -0800
commit6e0771665b3c9330fc0a5b2c7740a796b4cd712e (patch)
treec3e5b38d8e307146a127fe68b89f66e05395c8ce /sql
parenta170d34a1b309fecc76d1370063e0c4f44dc2142 (diff)
downloadspark-6e0771665b3c9330fc0a5b2c7740a796b4cd712e.tar.gz
spark-6e0771665b3c9330fc0a5b2c7740a796b4cd712e.tar.bz2
spark-6e0771665b3c9330fc0a5b2c7740a796b4cd712e.zip
[SQL] Update SQLContext.read.text doc
Since we rename the column name from ```text``` to ```value``` for DataFrame load by ```SQLContext.read.text```, we need to update doc. Author: Yanbo Liang <ybliang8@gmail.com> Closes #10349 from yanboliang/text-value.
Diffstat (limited to 'sql')
-rw-r--r--sql/core/src/main/scala/org/apache/spark/sql/DataFrameReader.scala2
-rw-r--r--sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/text/DefaultSource.scala2
2 files changed, 2 insertions, 2 deletions
diff --git a/sql/core/src/main/scala/org/apache/spark/sql/DataFrameReader.scala b/sql/core/src/main/scala/org/apache/spark/sql/DataFrameReader.scala
index 3ed1e55ade..c1a8f19313 100644
--- a/sql/core/src/main/scala/org/apache/spark/sql/DataFrameReader.scala
+++ b/sql/core/src/main/scala/org/apache/spark/sql/DataFrameReader.scala
@@ -339,7 +339,7 @@ class DataFrameReader private[sql](sqlContext: SQLContext) extends Logging {
}
/**
- * Loads a text file and returns a [[DataFrame]] with a single string column named "text".
+ * Loads a text file and returns a [[DataFrame]] with a single string column named "value".
* Each line in the text file is a new row in the resulting DataFrame. For example:
* {{{
* // Scala:
diff --git a/sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/text/DefaultSource.scala b/sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/text/DefaultSource.scala
index fbd387bc2e..4a1cbe4c38 100644
--- a/sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/text/DefaultSource.scala
+++ b/sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/text/DefaultSource.scala
@@ -76,7 +76,7 @@ private[sql] class TextRelation(
(@transient val sqlContext: SQLContext)
extends HadoopFsRelation(maybePartitionSpec, parameters) {
- /** Data schema is always a single column, named "text". */
+ /** Data schema is always a single column, named "value". */
override def dataSchema: StructType = new StructType().add("value", StringType)
/** This is an internal data source that outputs internal row format. */