[WIP][Extension][Spark] New Authz Plan Serde Layer

apache · Dec 6, 2022 · f56148e · f56148e
1 parent e47749d
commit f56148e
Show file tree

Hide file tree

Showing 8 changed files with 123 additions and 100 deletions.
diff --git a/extensions/spark/kyuubi-spark-authz/src/main/resources/database_command_spec.json b/extensions/spark/kyuubi-spark-authz/src/main/resources/database_command_spec.json
@@ -5,39 +5,39 @@
     "fieldExtractor" : "StringDatabaseExtractor",
     "isInput" : false
   } ],
-  "operationType" : "ALTERDATABASE"
+  "opType" : "ALTERDATABASE"
 }, {
   "classname" : "org.apache.spark.sql.execution.command.AlterDatabaseSetLocationCommand",
   "databaseDescs" : [ {
     "fieldName" : "databaseName",
     "fieldExtractor" : "StringDatabaseExtractor",
     "isInput" : false
   } ],
-  "operationType" : "ALTERDATABASE_LOCATION"
+  "opType" : "ALTERDATABASE_LOCATION"
 }, {
   "classname" : "org.apache.spark.sql.execution.command.CreateDatabaseCommand",
   "databaseDescs" : [ {
     "fieldName" : "databaseName",
     "fieldExtractor" : "StringDatabaseExtractor",
     "isInput" : false
   } ],
-  "operationType" : "CREATEDATABASE"
+  "opType" : "CREATEDATABASE"
 }, {
   "classname" : "org.apache.spark.sql.execution.command.DropDatabaseCommand",
   "databaseDescs" : [ {
     "fieldName" : "databaseName",
     "fieldExtractor" : "StringDatabaseExtractor",
     "isInput" : false
   } ],
-  "operationType" : "DROPDATABASE"
+  "opType" : "DROPDATABASE"
 }, {
   "classname" : "org.apache.spark.sql.execution.command.AnalyzeTablesCommand",
   "databaseDescs" : [ {
     "fieldName" : "databaseName",
     "fieldExtractor" : "StringOptionDatabaseExtractor",
     "isInput" : true
   } ],
-  "operationType" : "ANALYZE_TABLE"
+  "opType" : "ANALYZE_TABLE"
 }, {
   "classname" : "org.apache.spark.sql.catalyst.plans.logical.CreateNamespace",
   "databaseDescs" : [ {
@@ -49,39 +49,39 @@
     "fieldExtractor" : "StringSeqDatabaseExtractor",
     "isInput" : false
   } ],
-  "operationType" : "CREATEDATABASE"
+  "opType" : "CREATEDATABASE"
 }, {
   "classname" : "org.apache.spark.sql.catalyst.plans.logical.CommentOnNamespace",
   "databaseDescs" : [ {
     "fieldName" : "child",
     "fieldExtractor" : "ResolvedNamespaceDatabaseExtractor",
     "isInput" : false
   } ],
-  "operationType" : "ALTERDATABASE"
+  "opType" : "ALTERDATABASE"
 }, {
   "classname" : "org.apache.spark.sql.execution.command.DescribeDatabaseCommand",
   "databaseDescs" : [ {
     "fieldName" : "databaseName",
     "fieldExtractor" : "StringDatabaseExtractor",
     "isInput" : true
   } ],
-  "operationType" : "DESCDATABASE"
+  "opType" : "DESCDATABASE"
 }, {
   "classname" : "org.apache.spark.sql.catalyst.plans.logical.DescribeNamespace",
   "databaseDescs" : [ {
     "fieldName" : "namespace",
     "fieldExtractor" : "ResolvedNamespaceDatabaseExtractor",
     "isInput" : true
   } ],
-  "operationType" : "DESCDATABASE"
+  "opType" : "DESCDATABASE"
 }, {
   "classname" : "org.apache.spark.sql.catalyst.plans.logical.DropNamespace",
   "databaseDescs" : [ {
     "fieldName" : "namespace",
     "fieldExtractor" : "ResolvedNamespaceDatabaseExtractor",
     "isInput" : false
   } ],
-  "operationType" : "DROPDATABASE"
+  "opType" : "DROPDATABASE"
 }, {
   "classname" : "org.apache.spark.sql.catalyst.plans.logical.SetCatalogAndNamespace",
   "databaseDescs" : [ {
@@ -93,37 +93,37 @@
     "fieldExtractor" : "StringSeqOptionDatabaseExtractor",
     "isInput" : true
   } ],
-  "operationType" : "SWITCHDATABASE"
+  "opType" : "SWITCHDATABASE"
 }, {
   "classname" : "org.apache.spark.sql.execution.command.SetDatabaseCommand",
   "databaseDescs" : [ {
     "fieldName" : "databaseName",
     "fieldExtractor" : "StringDatabaseExtractor",
     "isInput" : true
   } ],
-  "operationType" : "SWITCHDATABASE"
+  "opType" : "SWITCHDATABASE"
 }, {
   "classname" : "org.apache.spark.sql.execution.command.SetNamespaceCommand",
   "databaseDescs" : [ {
     "fieldName" : "namespace",
     "fieldExtractor" : "StringSeqDatabaseExtractor",
     "isInput" : true
   } ],
-  "operationType" : "SWITCHDATABASE"
+  "opType" : "SWITCHDATABASE"
 }, {
   "classname" : "org.apache.spark.sql.catalyst.plans.logical.SetNamespaceProperties",
   "databaseDescs" : [ {
     "fieldName" : "namespace",
     "fieldExtractor" : "ResolvedNamespaceDatabaseExtractor",
     "isInput" : false
   } ],
-  "operationType" : "ALTERDATABASE"
+  "opType" : "ALTERDATABASE"
 }, {
   "classname" : "org.apache.spark.sql.catalyst.plans.logical.SetNamespaceLocation",
   "databaseDescs" : [ {
     "fieldName" : "namespace",
     "fieldExtractor" : "ResolvedNamespaceDatabaseExtractor",
     "isInput" : false
   } ],
-  "operationType" : "ALTERDATABASE_LOCATION"
+  "opType" : "ALTERDATABASE_LOCATION"
 } ]
diff --git a/extensions/spark/kyuubi-spark-authz/src/main/resources/function_command_spec.json b/extensions/spark/kyuubi-spark-authz/src/main/resources/function_command_spec.json
@@ -15,7 +15,7 @@
     },
     "isInput" : false
   } ],
-  "operationType" : "CREATEFUNCTION"
+  "opType" : "CREATEFUNCTION"
 }, {
   "classname" : "org.apache.spark.sql.execution.command.DropFunctionCommand",
   "functionDescs" : [ {
@@ -33,7 +33,7 @@
     },
     "isInput" : false
   } ],
-  "operationType" : "DROPFUNCTION"
+  "opType" : "DROPFUNCTION"
 }, {
   "classname" : "org.apache.spark.sql.execution.command.DescribeFunctionCommand",
   "functionDescs" : [ {
@@ -57,7 +57,7 @@
     },
     "isInput" : true
   } ],
-  "operationType" : "DESCFUNCTION"
+  "opType" : "DESCFUNCTION"
 }, {
   "classname" : "org.apache.spark.sql.execution.command.RefreshFunctionCommand",
   "functionDescs" : [ {
@@ -71,5 +71,5 @@
     "functionTypeDesc" : null,
     "isInput" : false
   } ],
-  "operationType" : "RELOADFUNCTION"
+  "opType" : "RELOADFUNCTION"
 } ]