imback82 commented on a change in pull request #29866:
URL: https://github.com/apache/spark/pull/29866#discussion_r494632218
##########
File path:
sql/core/src/main/scala/org/apache/spark/sql/execution/command/tables.scala
##########
@@ -1381,3 +1381,22 @@ case class ShowCreateTableAsSerdeCommand(table:
TableIdentifier)
}
}
}
+
+/**
+ * A command to refresh all cached entries associated with the table.
+ *
+ * The syntax of using this command in SQL is:
+ * {{{
+ * REFRESH TABLE [db_name.]table_name
+ * }}}
+ */
+case class RefreshTableCommand(tableIdent: TableIdentifier)
+ extends RunnableCommand {
+
+ override def run(sparkSession: SparkSession): Seq[Row] = {
+ // Refresh the given table's metadata. If this table is cached as an
InMemoryRelation,
+ // drop the original cached version and make the new version cached lazily.
+ sparkSession.catalog.refreshTable(tableIdent.quotedString)
+ Seq.empty[Row]
+ }
+}
Review comment:
This is moved from `ddl.scala` and `RefreshTable` is renamed to
`RefreshTableCommand`. Note that there is a TODO in this file that all the
commands in `ddl.scala` need to move here, so I will handle it separately.
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
---------------------------------------------------------------------
To unsubscribe, e-mail: reviews-unsubscr...@spark.apache.org
For additional commands, e-mail: reviews-h...@spark.apache.org
