我有一个包含10609行的数据框,我想将每次100行转换成JSON格式并发送回Web服务。
我尝试使用SQL的LIMIT子句,例如:
我尝试使用SQL的LIMIT子句,例如:
temptable = spark.sql("select item_code_1 from join_table limit 100")
这会返回前100行,但如果我想要接下来的100行,我尝试了这个方法但没有成功。
temptable = spark.sql("select item_code_1 from join_table limit 100, 200")
错误:Py4JJavaError:调用o22.sql时发生错误。: org.apache.spark.sql.catalyst.parser.ParseException:不匹配的输入 “,”预期(第1行,第44个位置)
== SQL ==
select item_code_1 from join_table limit 100, 200