apache-spark - 如何使用Spark/PySpark删除雪花目标表

Question

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

任何帮助人员，我找不到任何解决方案。

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