diff --git a/docs/sql-programming-guide.md b/docs/sql-programming-guide.md index 85d446b9da0e758137d0e91d7ee0847a3ab2fe81..be284fbe217a5fc6f2de2964ac9cb12cfdc99cf9 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])))