如何使用spark/pyspark删除雪花目标表

kzipqqlq  于 2021-05-27  发布在  Hadoop
关注(0)|答案(1)|浏览(403)

我试图删除一个目标雪花表,我已经创建了使用pyspark在databricks平台。
任何帮助的家伙,我找不到任何解决办法。

jaxagkaj

jaxagkaj1#

使用utils对象的runquery()方法执行ddl/dml sql语句,以及查询,例如:

var sfOptions = Map(
    "sfURL" -> "<account_name>.snowflakecomputing.com",
    "sfAccount" -> "<account_name>",
    "sfUser" -> "<user_name>",
    "sfPassword" -> "<password>",
    "sfDatabase" -> "<database>",
    "sfSchema" -> "<schema>",
    "sfWarehouse" -> "<warehouse>",
    )
Utils.runQuery(sfOptions, "DROP TABLE MY_TABLE")

雪花ddlSpark

相关问题