lanyuanxiaoyao/hudi
1
0
Fork 0
Code Activity

[MINOR] Update alter rename command class type for pattern matching (#5381)

Browse Source
This commit is contained in:
KnightChess
2022-04-27 10:39:51 +08:00
committed by GitHub
parent 77e333298d
commit 6ec039ba42
3 changed files with 5 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/spark/sql/hudi/command/AlterHoodieTableRenameCommand.scala
View File

@@ -27,11 +27,11 @@ import org.apache.spark.sql.execution.command.AlterTableRenameCommand
/** /**
* Command for alter hudi table's table name. * Command for alter hudi table's table name.
*/ */
class AlterHoodieTableRenameCommand( case class AlterHoodieTableRenameCommand(
oldName: TableIdentifier, oldName: TableIdentifier,
newName: TableIdentifier, newName: TableIdentifier,
isView: Boolean) isView: Boolean)
extends AlterTableRenameCommand(oldName, newName, isView) { extends HoodieLeafRunnableCommand {
override def run(sparkSession: SparkSession): Seq[Row] = { override def run(sparkSession: SparkSession): Seq[Row] = {
if (newName != oldName) { if (newName != oldName) {
@@ -45,7 +45,7 @@ class AlterHoodieTableRenameCommand(
.initTable(hadoopConf, hoodieCatalogTable.tableLocation) .initTable(hadoopConf, hoodieCatalogTable.tableLocation)
// Call AlterTableRenameCommand#run to rename table in meta. // Call AlterTableRenameCommand#run to rename table in meta.
super.run(sparkSession) AlterTableRenameCommand(oldName, newName, isView).run(sparkSession)
} }
Seq.empty[Row] Seq.empty[Row]
} }

2
hudi-spark-datasource/hudi-spark/src/main/scala/org/apache/spark/sql/hudi/analysis/HoodieAnalysis.scala
View File

@@ -526,7 +526,7 @@ case class HoodiePostAnalysisRule(sparkSession: SparkSession) extends Rule[Logic
// Rewrite the AlterTableRenameCommand to AlterHoodieTableRenameCommand // Rewrite the AlterTableRenameCommand to AlterHoodieTableRenameCommand
case AlterTableRenameCommand(oldName, newName, isView) case AlterTableRenameCommand(oldName, newName, isView)
if !isView && sparkAdapter.isHoodieTable(oldName, sparkSession) => if !isView && sparkAdapter.isHoodieTable(oldName, sparkSession) =>
new AlterHoodieTableRenameCommand(oldName, newName, isView) AlterHoodieTableRenameCommand(oldName, newName, isView)
// Rewrite the AlterTableChangeColumnCommand to AlterHoodieTableChangeColumnCommand // Rewrite the AlterTableChangeColumnCommand to AlterHoodieTableChangeColumnCommand
case AlterTableChangeColumnCommand(tableName, columnName, newColumn) case AlterTableChangeColumnCommand(tableName, columnName, newColumn)
if sparkAdapter.isHoodieTable(tableName, sparkSession) => if sparkAdapter.isHoodieTable(tableName, sparkSession) =>

2
hudi-spark-datasource/hudi-spark3/src/main/scala/org/apache/spark/sql/hudi/catalog/HoodieCatalog.scala
View File

@@ -139,7 +139,7 @@ class HoodieCatalog extends DelegatingCatalogExtension
override def renameTable(oldIdent: Identifier, newIdent: Identifier): Unit = { override def renameTable(oldIdent: Identifier, newIdent: Identifier): Unit = {
loadTable(oldIdent) match { loadTable(oldIdent) match {
case _: HoodieInternalV2Table => case _: HoodieInternalV2Table =>
new AlterHoodieTableRenameCommand(oldIdent.asTableIdentifier, newIdent.asTableIdentifier, false).run(spark) AlterHoodieTableRenameCommand(oldIdent.asTableIdentifier, newIdent.asTableIdentifier, false).run(spark)
case _ => super.renameTable(oldIdent, newIdent) case _ => super.renameTable(oldIdent, newIdent)
} }
} }