Skip to content

Commit be26846

Browse files
committed
update
1 parent 231ed33 commit be26846

File tree

1 file changed

+5
-9
lines changed
  • extensions/spark/kyuubi-spark-authz/src/main/scala/org/apache/kyuubi/plugin/spark/authz/serde

1 file changed

+5
-9
lines changed

extensions/spark/kyuubi-spark-authz/src/main/scala/org/apache/kyuubi/plugin/spark/authz/serde/tableExtractors.scala

Lines changed: 5 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -190,15 +190,11 @@ class ExpressionSeqTableExtractor extends TableExtractor {
190190
class ArrayBufferTableExtractor extends TableExtractor {
191191
override def apply(spark: SparkSession, v1: AnyRef): Option[Table] = {
192192
// Iceberg will transform table to ArrayBuffer[String]
193-
val expressions = v1.asInstanceOf[Seq[String]]
194-
val maybeTable = expressions.length match {
195-
case 1 => Table(None, None, expressions.head, None)
196-
case 2 => Table(None, Some(expressions.head), expressions(1), None)
197-
case 3 => Table(
198-
Some(expressions.head),
199-
Some(expressions(1)),
200-
expressions(2),
201-
None)
193+
val maybeTable = v1.asInstanceOf[Seq[String]] match {
194+
case Seq(tblName) => Table(None, None, tblName, None)
195+
case Seq(dbName, tblName) => Table(None, Some(dbName), tblName, None)
196+
case Seq(catalogName, dbName, tblName) =>
197+
Table(Some(catalogName), Some(dbName), tblName, None)
202198
}
203199
Option(maybeTable)
204200
}

0 commit comments

Comments
 (0)