0

如何使用 Livy 提交代码 pyspark?我用了这个,它有效

curl localhost:8998/sessions/0/statements -X POST -H 'Content-Type: application/json' -d '{"code":"srdd.get(\"ak\")"}'

但现在我要传递一个命令,例如这个

curl localhost:8998/sessions/69/statements -X POST -H 'Content-Type: application/json' -d  '{“code”: textwrap.dedent("""
from pyspark.sql import *
from pyspark.sql.types import *
B = spark.sql("SELECT * FROM A")
B.collect()”””
}'

但是有语法错误...谁知道写这个命令的正确性?

谢谢

谢谢

4

0 回答 0