如何在 Pyspark 中执行 SQL 查询？

Question

我正在尝试 运行 以下代码：

spark.sql('USE DATABASE test ;')

它给我错误：

pyspark.sql.utils.ParseException: 
extraneous input 'test' expecting {<EOF>, ';'}(line 1, pos 13)

如何解决这个问题？

Answer 1

语法是 - USE <database_name> 解释为 here。

通常，Spark SQL 语法已记录 here。