aboutsummaryrefslogtreecommitdiff
path: root/docs
diff options
context:
space:
mode:
authorAndy Konwinski <andykonwinski@gmail.com>2014-12-04 18:27:02 -0800
committerJosh Rosen <joshrosen@databricks.com>2014-12-04 18:27:18 -0800
commit63b1bc14ae131ee68959ff9c98a768a19cd6b5ba (patch)
treee5ac7f339caa3356d629fce099d2dd79fceebb5d /docs
parentb905e114e2084535dd78f29627b762505438e254 (diff)
downloadspark-63b1bc14ae131ee68959ff9c98a768a19cd6b5ba.tar.gz
spark-63b1bc14ae131ee68959ff9c98a768a19cd6b5ba.tar.bz2
spark-63b1bc14ae131ee68959ff9c98a768a19cd6b5ba.zip
Fix typo in Spark SQL docs.
Author: Andy Konwinski <andykonwinski@gmail.com> Closes #3611 from andyk/patch-3 and squashes the following commits: 7bab333 [Andy Konwinski] Fix typo in Spark SQL docs. (cherry picked from commit 15cf3b0125fe238dea2ce13e703034ba7cef477f) Signed-off-by: Josh Rosen <joshrosen@databricks.com>
Diffstat (limited to 'docs')
-rw-r--r--docs/sql-programming-guide.md2
1 files changed, 1 insertions, 1 deletions
diff --git a/docs/sql-programming-guide.md b/docs/sql-programming-guide.md
index 85d446b9da..be284fbe21 100644
--- a/docs/sql-programming-guide.md
+++ b/docs/sql-programming-guide.md
@@ -278,7 +278,7 @@ performed on JSON files.
from pyspark.sql import SQLContext, Row
sqlContext = SQLContext(sc)
-# Load a text file and convert each line to a dictionary.
+# Load a text file and convert each line to a Row.
lines = sc.textFile("examples/src/main/resources/people.txt")
parts = lines.map(lambda l: l.split(","))
people = parts.map(lambda p: Row(name=p[0], age=int(p[1])))