pyspark sql错误:sql()缺少1个必需的位置参数:“sqlquery”

oalqel3c  于 2021-05-16  发布在  Spark
关注(0)|答案(0)|浏览(646)

我是spark的新手,尝试在python中使用spark sql从配置单元提取数据,方法如下:

from pyspark.sql import SparkSession, SQLContext
sdf = SparkSession.sql("select * from gaa_prm.detail limit 5")

错误如下:

sql() missing 1 required positional argument: 'sqlQuery'

我知道我需要先创建一个spark会话,因此尝试了以下操作,但出现了其他错误:
1

spark = SparkSession.getOrCreate()

type object 'SparkSession' has no attribute 'getOrCreate'

spark=sparksession.builder sdf=spark.sql(“从gaa\u prm.detail limit 5中选择*”)
“builder”对象没有属性“sql”
你能建议一下吗?

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题