我是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”
你能建议一下吗?
暂无答案!
目前还没有任何答案,快来回答吧!