[jira] [Updated] (SPARK-15031) Use SparkSession in Scala/Python example.

["Dongjoon Hyun (JIRA)" <ji...@apache.org>]

     [ https://issues.apache.org/jira/browse/SPARK-15031?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Dongjoon Hyun updated SPARK-15031:
----------------------------------
    Issue Type: Improvement  (was: Bug)

> Use SparkSession in Scala/Python example.
> -----------------------------------------
>
>                 Key: SPARK-15031
>                 URL: https://issues.apache.org/jira/browse/SPARK-15031
>             Project: Spark
>          Issue Type: Improvement
>          Components: Examples
>            Reporter: Dongjoon Hyun
>            Priority: Trivial
>
> Currently, Python SQL example, `sql.py`, fails.
> {code}
> bin/spark-submit examples/src/main/python/sql.py
> Traceback (most recent call last):
>   File "/Users/dongjoon/spark-release/spark-2.0/examples/src/main/python/sql.py", line 60, in <module>
>     people = sqlContext.jsonFile(path)
> AttributeError: 'SQLContext' object has no attribute 'jsonFile'
> {code}
> {code}
> Traceback (most recent call last):
>   File "/Users/dongjoon/spark-release/spark-2.0/examples/src/main/python/sql.py", line 72, in <module>
>     people.registerAsTable("people")
>   File "/Users/dongjoon/spark/python/lib/pyspark.zip/pyspark/sql/dataframe.py", line 795, in __getattr__
> AttributeError: 'DataFrame' object has no attribute 'registerAsTable'
> {code}
> This issue fixes them by the following fix.
> {code}
> -    people = sqlContext.jsonFile(path)
> +    people = sqlContext.read.json(path)
> ...
> -    people.registerAsTable("people")
> +    people.registerTempTable("people")
> {code}



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

---------------------------------------------------------------------
To unsubscribe, e-mail: issues-unsubscribe@spark.apache.org
For additional commands, e-mail: issues-help@spark.apache.org