我了解如何在 PySpark 中检查表是否存在:
>>> spark.catalog.setCurrentDatabase("staging")
>>> 'test_table' in sqlContext.tableNames()
True
但是 View 呢？
如果它像这样创建它:
df = sqlContext.sql("SELECT * FROM staging.test_table")
df.createOrReplaceTempView("test_view")
df.persist(p.persistLevel)
如何检查我的代码后面是否存在“测试 View ”？
最佳答案
您可以使用 sqlContext.tableNames 和 sqlContext.tables
>>> sqlContext.registerDataFrameAsTable(df, "table1")
>>> "table1" in sqlContext.tableNames()
True
>>> "table1" in sqlContext.tableNames("default")
True
关于pyspark - 如何检查 PySpark 中是否存在临时 View ？，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/52766215/