我正试图为数据帧编写一个spark-select查询,如下所示:
val ans=spark.sql(按approve_visa DESC Limit 10的empname顺序从visa组中选择empname,count(visa_class(作为Approved_visa(
我得到以下错误:方法sql(sql文本字符串(org.apache.spark.sql.dataframe的参数太多
看起来像是语法错误。您需要提供带引号的SQL语句。示例:
val ans = spark.sql("select * from table")