aboutsummaryrefslogtreecommitdiff
path: root/docs
diff options
context:
space:
mode:
authorSun Rui <rui.sun@intel.com>2015-07-08 09:48:16 -0700
committerShivaram Venkataraman <shivaram@cs.berkeley.edu>2015-07-08 09:48:16 -0700
commitbf02e377168f39459d5c216e939097ae5705f573 (patch)
treec33d850fa3c09dcf3052ee3602f2c7c651a483d7 /docs
parent3bb217750ada18a49c40d974ac57050ef2abfd2c (diff)
downloadspark-bf02e377168f39459d5c216e939097ae5705f573.tar.gz
spark-bf02e377168f39459d5c216e939097ae5705f573.tar.bz2
spark-bf02e377168f39459d5c216e939097ae5705f573.zip
[SPARK-8894] [SPARKR] [DOC] Example code errors in SparkR documentation.
Author: Sun Rui <rui.sun@intel.com> Closes #7287 from sun-rui/SPARK-8894 and squashes the following commits: da63898 [Sun Rui] [SPARK-8894][SPARKR][DOC] Example code errors in SparkR documentation.
Diffstat (limited to 'docs')
-rw-r--r--docs/sparkr.md2
-rw-r--r--docs/sql-programming-guide.md2
2 files changed, 2 insertions, 2 deletions
diff --git a/docs/sparkr.md b/docs/sparkr.md
index 095ea4308c..1197c0d601 100644
--- a/docs/sparkr.md
+++ b/docs/sparkr.md
@@ -116,7 +116,7 @@ sql(hiveContext, "CREATE TABLE IF NOT EXISTS src (key INT, value STRING)")
sql(hiveContext, "LOAD DATA LOCAL INPATH 'examples/src/main/resources/kv1.txt' INTO TABLE src")
# Queries can be expressed in HiveQL.
-results <- hiveContext.sql("FROM src SELECT key, value")
+results <- sql(hiveContext, "FROM src SELECT key, value")
# results is now a DataFrame
head(results)
diff --git a/docs/sql-programming-guide.md b/docs/sql-programming-guide.md
index 7c25578979..26f6ba84b9 100644
--- a/docs/sql-programming-guide.md
+++ b/docs/sql-programming-guide.md
@@ -1637,7 +1637,7 @@ sql(sqlContext, "CREATE TABLE IF NOT EXISTS src (key INT, value STRING)")
sql(sqlContext, "LOAD DATA LOCAL INPATH 'examples/src/main/resources/kv1.txt' INTO TABLE src")
# Queries can be expressed in HiveQL.
-results = sqlContext.sql("FROM src SELECT key, value").collect()
+results <- collect(sql(sqlContext, "FROM src SELECT key, value"))
{% endhighlight %}