From e88c61027279b28f341974a0befb3361fa17faa1 Mon Sep 17 00:00:00 2001 From: xuyu <11161569@vivo.com> Date: Thu, 1 Aug 2024 20:34:08 +0800 Subject: [PATCH] fix --- .../execution/datasources/v2/ShowColumnsTableExec.scala | 9 +-------- 1 file changed, 1 insertion(+), 8 deletions(-) diff --git a/sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/v2/ShowColumnsTableExec.scala b/sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/v2/ShowColumnsTableExec.scala index cdfcbde4917f6..61450c229c377 100644 --- a/sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/v2/ShowColumnsTableExec.scala +++ b/sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/v2/ShowColumnsTableExec.scala @@ -20,7 +20,6 @@ package org.apache.spark.sql.execution.datasources.v2 import org.apache.spark.sql.catalyst.InternalRow import org.apache.spark.sql.catalyst.analysis.ResolvedTable import org.apache.spark.sql.catalyst.expressions.Attribute -import org.apache.spark.sql.catalyst.util.CharVarcharUtils import org.apache.spark.sql.execution.LeafExecNode import org.apache.spark.unsafe.types.UTF8String @@ -37,14 +36,8 @@ case class ShowColumnsTableExec( } private def showColumnsTable(resolvedTable: ResolvedTable, builder: StringBuilder): Unit = { - import org.apache.spark.sql.connector.catalog.CatalogV2Implicits._ val table = resolvedTable.table; - val columns = CharVarcharUtils.getRawSchema(table.columns.asSchema, conf).fields.map(_.toDDL) - builder ++= concatByMultiLines(columns) - } - - private def concatByMultiLines(iter: Iterable[String]): String = { - iter.mkString("(\n ", ",\n ", ")\n") + table.columns().foreach(f => builder.append(f.name()).append("\n")) } }