From 6b74391a87abf4907479f933e7bd8ffaf5e045b6 Mon Sep 17 00:00:00 2001 From: Matei Alexandru Zaharia Date: Sun, 26 Jul 2015 19:10:57 +0000 Subject: Further improvements to site --- sql/index.md | 14 +++++++------- 1 file changed, 7 insertions(+), 7 deletions(-) (limited to 'sql') diff --git a/sql/index.md b/sql/index.md index 630c4c27c..e742f5f16 100644 --- a/sql/index.md +++ b/sql/index.md @@ -26,8 +26,8 @@ subproject: SQL
- sqlCtx = new HiveContext(sc)
- results = sqlCtx.sql(
  "SELECT * FROM people")
+ context = new HiveContext(sc)
+ results = context.sql(
  "SELECT * FROM people")
names = results.map(lambda p: p.name)
Apply functions to results of SQL queries.
@@ -48,11 +48,11 @@ subproject: SQL
- sqlCtx.jsonFile("s3n://...")
  .registerAsTable("json")
- results = sqlCtx.sql("""
-   SELECT *
-   FROM hiveTable
-   JOIN json ...""")
+ context.jsonFile("s3n://...")
  .registerTempTable("json")
+ results = context.sql(
+   """SELECT *
+      FROM people
+      JOIN json ...""")
Query and join different data sources.
-- cgit v1.2.3