'SparkSession' Object Has No Attribute 'sqlContext' - How to Fix
This error occurs when you try to access the 'sqlContext' attribute on a SparkSession object. Spark 2.0+ has deprecated the 'sqlContext' attribute in favor of the 'spark' attribute.
To access the SQLContext in Spark 2.0+, you need to use the 'spark' attribute to create a new SQLContext object as follows:
from pyspark.sql import SparkSession
spark = SparkSession.builder.appName('MyApp').getOrCreate()
sqlContext = spark.sqlContext
Alternatively, you can directly use the 'spark' attribute to perform SQL operations as follows:
from pyspark.sql import SparkSession
spark = SparkSession.builder.appName('MyApp').getOrCreate()
df = spark.sql('SELECT * FROM my_table')
原文地址: https://www.cveoy.top/t/topic/oYI8 著作权归作者所有。请勿转载和采集!