From fbfa98d21cefe08809c7a58b0fa527b704c4008c Mon Sep 17 00:00:00 2001 From: hyukjinkwon Date: Mon, 9 May 2016 20:56:43 +0900 Subject: [PATCH 1/2] Typo in examples (sqlContext should be SparkSession) --- .../main/java/org/apache/spark/examples/sql/JavaSparkSQL.java | 2 +- examples/src/main/python/sql.py | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/examples/src/main/java/org/apache/spark/examples/sql/JavaSparkSQL.java b/examples/src/main/java/org/apache/spark/examples/sql/JavaSparkSQL.java index 755b4f538104..5ac9f51b2457 100644 --- a/examples/src/main/java/org/apache/spark/examples/sql/JavaSparkSQL.java +++ b/examples/src/main/java/org/apache/spark/examples/sql/JavaSparkSQL.java @@ -133,7 +133,7 @@ public String call(Row row) { // Register this DataFrame as a table. peopleFromJsonFile.registerTempTable("people"); - // SQL statements can be run by using the sql methods provided by sqlContext. + // SQL statements can be run by using the sql methods provided by spark (SparkSession object). Dataset teenagers3 = spark.sql("SELECT name FROM people WHERE age >= 13 AND age <= 19"); // The results of SQL queries are DataFrame and support all the normal RDD operations. diff --git a/examples/src/main/python/sql.py b/examples/src/main/python/sql.py index 5594223465f8..a43c5b6b8dea 100644 --- a/examples/src/main/python/sql.py +++ b/examples/src/main/python/sql.py @@ -69,7 +69,7 @@ # Register this DataFrame as a temporary table. people.registerTempTable("people") - # SQL statements can be run by using the sql methods provided by sqlContext + # SQL statements can be run by using the sql methods provided by spark (SparkSession object) teenagers = spark.sql("SELECT name FROM people WHERE age >= 13 AND age <= 19") for each in teenagers.collect(): From 3c530adf4e21d616dc9ffb546fd19e562875694c Mon Sep 17 00:00:00 2001 From: hyukjinkwon Date: Mon, 9 May 2016 20:59:42 +0900 Subject: [PATCH 2/2] Same ending dot at Java and Python examples --- examples/src/main/python/sql.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/examples/src/main/python/sql.py b/examples/src/main/python/sql.py index a43c5b6b8dea..1acdd1e1b0e9 100644 --- a/examples/src/main/python/sql.py +++ b/examples/src/main/python/sql.py @@ -69,7 +69,7 @@ # Register this DataFrame as a temporary table. people.registerTempTable("people") - # SQL statements can be run by using the sql methods provided by spark (SparkSession object) + # SQL statements can be run by using the sql methods provided by spark (SparkSession object). teenagers = spark.sql("SELECT name FROM people WHERE age >= 13 AND age <= 19") for each in teenagers.collect():