如何使用 Spark/PySpark 删除雪花目标 table

Question

我正在尝试删除我在 Databricks 平台中使用 Pyspark 创建的目标雪花 table。

任何帮助家伙，我找不到任何解决方案。

Answer 1

使用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")

Snowflake DDL spark