cases, count (*) as count GROUP BY county, state, deaths, cases 我通过SQL从上面的查询中获得以下数据。我想要的是将这两个SQL查询转换为PySpark请让我知道,因为我对熊猫和PySpark都是新手
注意-我不想使用spark.sql,而是希望使用spark.table从表
我现在正在将sql server查询转换为sql。我遇到了转换给定查询的问题我已经在它上面工作过,并且知道spark不支持我使用过的“不存在”命令,但错误是
pyspark.sql.utils.AnalysisException: u'Except can only be performed on tables with th
我从RDS运行了一个查询,并使用Pyspark将查询转换为DataFrame。/sql/session.py", line 748, in createDataFrame
rdd, schema = self./lib/python3.6/site-packages/pyspark/sql/session.py", line 730, in pr