在SQL中有:
REFRESH TABLE table_name
在火星雨中,对应的是:
spark.refreshTable(table_name)
那么,什么是火星之火相当于:
MSCK REPAIR TABLE table_name
发布于 2019-05-16 16:23:59
refreshTable与火花会话目录集成。
正如史蒂文所建议的,你可以和spark.sql('MSCK REPAIR TABLE table_name')一起去
spark.sql('MSCK REPAIR TABLE table_name')
在上面的链接中有一个叫做recoverPartitions的东西(只适用于已分区表,而不是视图)。我相信这是msck repair table的别名版本。你可以试试这个..。
recoverPartitions
msck repair table
请看,这个ddl.scala似乎在文档中是相等的。
示例用法:
spark.catalog.recoverPartitions(tableName)
https://stackoverflow.com/questions/56169722
相似问题