ODIn/spark-instrumented-optimizer
1
0
Fork 0
Code Issues Pull requests Projects Releases Wiki Activity

updated java code blocks in spark SQL guide such that ctx will refer to ...

Browse source 
...a JavaSparkContext and sqlCtx will refer to a JavaSQLContext

Author: Yadid Ayzenberg <yadid@media.mit.edu>

Closes #932 from yadid/master and squashes the following commits:

f92fb3a [Yadid Ayzenberg] updated java code blocks in spark SQL guide such that ctx will refer to a JavaSparkContext and sqlCtx will refer to a JavaSQLContext
This commit is contained in:
Yadid Ayzenberg 2014-05-31 19:44:13 -07:00 committed by Reynold Xin
parent 5e98967b61
commit 366c0c4c30
1 changed files with 3 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
docs/sql-programming-guide.md
View file

@ -170,7 +170,9 @@ A schema can be applied to an existing RDD by calling `applySchema` and providin
for the JavaBean. for the JavaBean.
{% highlight java %} {% highlight java %}
JavaSQLContext ctx = new org.apache.spark.sql.api.java.JavaSQLContext(sc)
JavaSparkContext ctx = ...; // An existing JavaSparkContext.
JavaSQLContext sqlCtx = new org.apache.spark.sql.api.java.JavaSQLContext(ctx)
// Load a text file and convert each line to a JavaBean. // Load a text file and convert each line to a JavaBean.
JavaRDD<Person> people = ctx.textFile("examples/src/main/resources/people.txt").map( JavaRDD<Person> people = ctx.textFile("examples/src/main/resources/people.txt").map(