[kylin] 11/35: KYLIN-5637 minor fix get delta table ddl (#30286)

[xxyu]

This is an automated email from the ASF dual-hosted git repository.

xxyu pushed a commit to branch kylin5
in repository https://gitbox.apache.org/repos/asf/kylin.git

commit 3436ae7b9b6e4f99ac7704775cb05be6ea058337
Author: Jiawei Li <1019037...@qq.com>
AuthorDate: Fri Apr 14 16:20:00 2023 +0800

    KYLIN-5637 minor fix get delta table ddl (#30286)
---
 .../sparder/src/main/scala/org/apache/spark/sql/DdlOperation.scala | 7 +++++--
 1 file changed, 5 insertions(+), 2 deletions(-)

diff --git 
a/src/spark-project/sparder/src/main/scala/org/apache/spark/sql/DdlOperation.scala
 
b/src/spark-project/sparder/src/main/scala/org/apache/spark/sql/DdlOperation.scala
index 125407dd10..8f19c9dd06 100644
--- 
a/src/spark-project/sparder/src/main/scala/org/apache/spark/sql/DdlOperation.scala
+++ 
b/src/spark-project/sparder/src/main/scala/org/apache/spark/sql/DdlOperation.scala
@@ -113,8 +113,7 @@ object DdlOperation extends Logging {
     var tableMetadata = SparderEnv.getSparkSession.sessionState.catalog
       .getTableRawMetadata(TableIdentifier(table, Some(database)))
     if (DeltaTableUtils.isDeltaTable(tableMetadata)) {
-      return  new ShowCreateTableCommand(TableIdentifier(table, 
Some(database)), Seq.empty).
-        run(SparderEnv.getSparkSession).toList.take(1).head.getString(0);
+      return generateDeltaTableDDL(tableMetadata);
     }
     sql = if (DDLUtils.isHiveTable(tableMetadata)) sql + " AS SERDE" else sql
     val logicalPlan = 
SparderEnv.getSparkSession.sessionState.sqlParser.parsePlan(sql)
@@ -126,6 +125,10 @@ object DdlOperation extends Logging {
     }
   }
 
+  def generateDeltaTableDDL(tableMetadata: CatalogTable): String = {
+    s"CREATE TABLE ${tableMetadata.identifier.quotedString} USING delta 
LOCATION '${tableMetadata.location}'"
+  }
+
 
   def collectDDL(tableIdentifier: TableIdentifier, sql: String): String = {
     val catalog: SessionCatalog = 
SparderEnv.getSparkSession.sessionState.catalog