This is an automated email from the ASF dual-hosted git repository.
jshao pushed a change to branch
dependabot/pip/clients/client-python/cachetools-6.2.1
in repository https://gitbox.apache.org/repos/asf/gravitino.git
from dd733bc4bb Merge branch 'main' into
dependabot/pip/clients/client-python/cachetools-6.2.1
add ddcdd8ee83 [#8730][Improvement] Fix CLI distribution output when
distribution is none (#9066)
add 7944f4ff92 [#9036] feat(authz): add document and api for tag access
control (#9035)
add c295b9470a [#7144] feat(policy): Add event listener support for policy
(#9004)
add 4b4a1916c2 [#8824] fix(core): Fix bugs in the logic about reverse
index in entity store Caffeine cache (#9068)
add 4a411c86f6 [#9081] fix(catalog): use correct operation type in catalog
update error handler in CatalogOperations.java (#9092)
add 749071f9fe [#9046] feat(iceberg):Upgrade iceberg 1.10.0 for support
scan planning. (#9049)
add ad450e59af [#9085] fix(core): enforce minimum jobStatusKeepTimeInMs
instead of throwing IllegalArgumentException. (#9102)
add b97bd9412b [#8797] feat(client-python): add class AddPartitionsRequest
(#9045)
add 07569cc98b [#8625] feat(client-python): add partition oriented
responses (#9096)
add 76d3138428 [#9077] fix(dto): Ensure updates list is not null (#9094)
add b6a3c69cef [#8899] feat(iceberg): Supports Jdbc Iceberg metrics store
(#9010)
add 3443e06653 [#8833][#8834] feat(catalogs): Generic lakehouse catalog,
table storage enhancement (#9116)
add 07fb3dddd9 [#9125] Replace UNKNOWN_USER with UNKNOWN_ENTITY in
NoSuchMetadataObjectException (#9131)
add e195feea68 [#9095] fix(dto): Ensure index field names are not null
(#9118)
add eaba9a23c5 [#9122] [Improvement]: Prevent potential null pointer error
in MetadataObjectStatisticsOperations.java (#9134)
add 6de1ae69cf [#9042] Add postgresql backend in chart (#9051)
add bcebcda464 [#9140] fix(autzh): fix fileset authorization expression
(#9149)
add 1721497e9d [#8835][#8836] feat(lakehouseCatalog): supports catalog and
schema operations for lakehouse catalog (#9130)
add 320637a3e4 [#9139] fix(lock): Prevent NPE when timestamp is missing in
TreeLock.unlock (#9146)
add eb4afe8cfe [#9121] fix(auth): Correct KeyFactory handling for ECDSA
algorithms (#9141)
add af79aef70d [#9124] Handle negative partNo safely and fix test file
typo (#9128)
add 9526257c3d [#9104] improvement(authz): support list and get roles when
has manage_grants (#9114)
add 0872b14bdc Improvement: changed alias version when it should be named
alias (#9163)
add 8f7bc49df1 [#9137] fix(stats): initialize comparator with
DEFAULT_COMPARATOR in default constructor (#9175)
add fca9e35401 Fixed UI routes ending in WebUIFilter (#9135)
add 3213cfb20d [#9171] improvement(authz): remove loadedOwners in
JcasbinAuthorizer (#9172)
add 8def4021b6 [#8890][#8891][#8909] feat(lance server): Lance rest server
framework (#9174)
add 536eb6fb51 [#8838][#8837] feat(catalogs): Support create/load/list
table operation for lance table (#9181)
add 60b822b39d [#8892][#8893] feat(Lance-REST-Server): Lance namespace and
table operations (#9182)
add 751a5e7df9 [#9072] feat(authz): Add document and api for policy access
control (#9115)
add 904f635b45 [#8919] improve(lance-table): Supports object store
configurations for lance table storage (#9185)
add 70051f81f4 [#8921] improvement(catalogs): Add ITs for lance table
operations (#9190)
add b8245a1edf [#8933][#8959] fix(lance-rest-server): fix lance rest
server issues (#9186)
add 12ac05c2df [#7556] [#7740] [#7741] feat(iceberg): add authz for table
operations in Iceberg REST server (#9192)
add 8ddb17436c [#8710] feat(core): Support cache entities in relation
operations. (#8712)
add 286b9521f0 [#8962] improvement(lance): supports more dataTypes for the
Lance rest server (#9195)
add bec415fb99 [#9100] improvement(trino-connector): Use
GravitinoColumnHandle for getTableStatistics in GravitinoMetadata (#9101)
add dda4328177 [#9180] fix(spark-connector): Override tableExists() to
bypass authorization check (#9183)
add 5583c84f29 [#8915] improvement(catalogs): Lance code refactor (#9196)
add e850494a74 [#8955] feat(lance-rest): Support register and deregister
table operations in Lance REST server (#9197)
add a30b149f8e [#8940] improvement(core): Support serialize/deserialize
for distributionImpl and sortOrderImpl (#9198)
add ab840a5fef [#7556][followup] fix(authz,iceberg): Fix the issues of
creating tables and renaming tables. (#9200)
add 2314743bc2 [#9136] fix(doris): trim bucket number to prevent
NumberFormatException (#9189)
add f1ca524dc2 [#8942]feat(authz): support tag access control (#9018)
add c511fa272b [#9009][#9015] improvement(lance-rest): Add integration
tests and unit tests for Lance REST Service (#9209)
add 4c5d464a71 [#9028] improve(core): Refactor the table and table entity
to avoid introducing unnecessary interfaces (#9215)
add e90fe35cb6 [#8939][#9093] Improvement(lance-catalog): Fix register
table endpoint and make Lance operations atomic (#9216)
add c84693dc4c [#9210] feat(iceberg) : Add authorization for Iceberg
Namespace operations (#9211)
add 4d33878492 [#9213]: fix(iceberg): Override namespace owner with OAuth
authenticated user (#9212)
add 091dfc1121 [#7556][followup] Iceberg table authz tests (#9214)
add 25baab7f18 [#9022] improve(core): Refactor to add the managed table
operations (#9217)
add 7ead18cc49 [#7556][followup] feat: Get the credential with the correct
privileges (#9218)
add 17928301ce [#9220] feat(iceberg): Add authorization for
cross-namespace table renames (#9219)
add 866eef7a8c [#9075] fix CLI jar selection when multiple CLI jars exist
(issue #9075) (#9203)
add 34556b6e6c [#9223] test(authz): Add GCP credential vending IT (#9222)
add fcd2c5b3bf [#9193] improvement(lance-rest): Automatically build
necessary modules when running Lance REST integration tests. (#9194)
add 02f7ca5920 Merge branch 'main' into
dependabot/pip/clients/client-python/cachetools-6.2.1
No new revisions were added by this update.
Summary of changes:
.github/workflows/chart-test.yaml | 6 +-
api/build.gradle.kts | 2 +
.../java/org/apache/gravitino/MetadataObject.java | 9 +-
.../java/org/apache/gravitino/MetadataObjects.java | 9 +-
.../apache/gravitino/authorization/Privilege.java | 11 +-
.../apache/gravitino/authorization/Privileges.java | 160 ++++-
.../main/java/org/apache/gravitino/rel/Table.java | 40 ++
.../org/apache/gravitino/rel/indexes/Index.java | 45 ++
.../org/apache/gravitino/rel/indexes/Indexes.java | 24 +
.../org/apache/gravitino/stats/PartitionRange.java | 4 +-
.../authorization/TestSecurableObjects.java | 37 +
.../apache/gravitino/stats/TestPartitionRange.java | 12 +
bin/gcli.sh.template | 2 +-
build.gradle.kts | 5 +-
.../build.gradle.kts | 46 +-
.../lakehouse/GenericLakehouseCatalog.java} | 46 +-
.../GenericLakehouseCatalogCapability.java | 8 +-
.../GenericLakehouseCatalogOperations.java | 487 +++++++++++++
...GenericLakehouseCatalogPropertiesMetadata.java} | 38 +-
.../GenericLakehouseSchemaPropertiesMetadata.java} | 35 +-
.../GenericLakehouseTablePropertiesMetadata.java | 81 +++
.../lakehouse/LakehouseCatalogOperations.java | 36 +-
.../catalog/lakehouse/LakehouseTableFormat.java} | 26 +-
.../lakehouse/lance/LanceCatalogOperations.java | 299 ++++++++
.../catalog/lakehouse/utils/EntityConverter.java | 35 +-
.../services/org.apache.gravitino.CatalogProvider | 2 +-
.../src/main/resources/generic-lakehouse.conf | 6 +-
.../TestGenericLakehouseCatalogOperations.java | 232 +++++++
.../catalog/lakehouse/TestPropertiesMetadata.java | 102 +++
.../test/CatalogGenericLakehouseLanceIT.java | 493 ++++++++++++++
.../lakehouse/utils/TestEntityConverter.java | 78 +++
.../gravitino/catalog/doris/utils/DorisUtils.java | 4 +-
.../catalog/doris/utils/TestDorisUtils.java | 21 +
.../catalog-lakehouse-iceberg/build.gradle.kts | 7 +
.../integration/test/CatalogIcebergBaseIT.java | 2 +-
.../test/CatalogIcebergKerberosHiveIT.java | 2 +-
.../java/org/apache/gravitino/cli/FullName.java | 2 +-
.../cli/commands/RemoveModelVersionProperty.java | 2 +-
.../cli/commands/RevokePrivilegesFromRole.java | 2 +-
.../gravitino/cli/commands/TableDistribution.java | 7 +-
.../cli/{TestFulllName.java => TestFullName.java} | 21 +-
.../org/apache/gravitino/cli/TestRoleCommands.java | 25 +
.../client/MetadataObjectStatisticsOperations.java | 3 +
.../gravitino/client/TestRelationalCatalog.java | 10 -
.../gravitino/client/TestSupportsStatistics.java | 9 +
.../test/authorization/RoleAuthorizationIT.java | 18 +
.../test/authorization/TableAuthorizationIT.java | 10 +
.../TagOperationsAuthorizationIT.java | 300 ++++++++
...og_set_request.py => add_partitions_request.py} | 24 +-
...drop_response.py => partition_list_response.py} | 23 +-
.../{drop_response.py => partition_response.py} | 19 +-
.../gravitino/dto/util/dto_converters.py | 107 ++-
.../unittests/dto/util/test_dto_converters.py | 182 ++++-
.../client-python/tests/unittests/test_requests.py | 41 ++
.../tests/unittests/test_responses.py | 55 ++
.../apache/gravitino/config/ConfigConstants.java | 2 +-
.../org/apache/gravitino/dto/rel/TableDTO.java | 2 -
.../dto/requests/CatalogUpdatesRequest.java | 2 +
.../dto/requests/JobTemplateUpdatesRequest.java | 2 +
.../dto/requests/MetalakeUpdatesRequest.java | 2 +
.../dto/requests/ModelUpdatesRequest.java | 2 +
.../dto/requests/SchemaUpdatesRequest.java | 2 +
.../gravitino/dto/requests/TableCreateRequest.java | 8 +-
.../dto/requests/TableUpdatesRequest.java | 2 +
.../dto/requests/TopicUpdatesRequest.java | 2 +
.../gravitino/dto/responses/TableResponse.java | 3 -
.../java/org/apache/gravitino/json/JsonUtils.java | 28 +-
.../org/apache/gravitino/dto/rel/TestTableDTO.java | 13 +-
.../org/apache/gravitino/json/TestSerializer.java | 186 +++++
conf/gravitino-lance-rest-server.conf.template | 49 ++
conf/gravitino.conf.template | 19 +-
core/build.gradle.kts | 3 +
.../java/org/apache/gravitino/GravitinoEnv.java | 11 +-
.../authorization/AuthorizationUtils.java | 4 +-
.../gravitino/cache/CaffeineEntityCache.java | 119 +++-
.../apache/gravitino/cache/ReverseIndexCache.java | 44 +-
.../apache/gravitino/cache/ReverseIndexRules.java | 40 ++
.../gravitino/catalog/ManagedSchemaOperations.java | 2 +-
.../gravitino/catalog/ManagedTableOperations.java | 538 +++++++++++++++
.../catalog/TableOperationDispatcher.java | 78 +++
.../apache/gravitino/connector/GenericColumn.java | 61 ++
.../connector/GenericLakehouseColumn.java | 57 ++
.../gravitino/connector/GenericLakehouseTable.java | 69 ++
.../apache/gravitino/connector/GenericTable.java | 71 ++
.../apache/gravitino/hook/TableHookDispatcher.java | 1 +
.../apache/gravitino/hook/TagHookDispatcher.java | 113 +++
.../gravitino/job/local/LocalJobExecutor.java | 1 +
.../gravitino/listener/PolicyEventDispatcher.java | 374 ++++++++++
.../listener/api/event/OperationType.java | 14 +
.../api/event/policy/AlterPolicyEvent.java | 84 +++
.../AlterPolicyFailureEvent.java} | 38 +-
.../AlterPolicyPreEvent.java} | 31 +-
.../AssociatePoliciesForMetadataObjectEvent.java | 94 +++
...ciatePoliciesForMetadataObjectFailureEvent.java | 96 +++
...AssociatePoliciesForMetadataObjectPreEvent.java | 91 +++
.../CreatePolicyEvent.java} | 40 +-
.../CreatePolicyFailureEvent.java} | 38 +-
.../CreatePolicyPreEvent.java} | 32 +-
.../DeletePolicyEvent.java} | 30 +-
.../DeletePolicyFailureEvent.java} | 20 +-
.../DeletePolicyPreEvent.java} | 19 +-
.../DisablePolicyEvent.java} | 19 +-
.../DisablePolicyFailureEvent.java} | 20 +-
.../DisablePolicyPreEvent.java} | 19 +-
.../EnablePolicyEvent.java} | 19 +-
.../EnablePolicyFailureEvent.java} | 20 +-
.../EnablePolicyPreEvent.java} | 19 +-
.../GetPolicyEvent.java} | 31 +-
.../GetPolicyFailureEvent.java} | 24 +-
.../GetPolicyForMetadataObjectEvent.java} | 52 +-
.../GetPolicyForMetadataObjectFailureEvent.java | 83 +++
.../GetPolicyForMetadataObjectPreEvent.java} | 52 +-
.../GetPolicyPreEvent.java} | 19 +-
.../ListMetadataObjectsForPolicyEvent.java} | 22 +-
.../ListMetadataObjectsForPolicyFailureEvent.java} | 24 +-
.../ListMetadataObjectsForPolicyPreEvent.java} | 21 +-
.../ListPoliciesEvent.java} | 22 +-
.../ListPoliciesFailureEvent.java} | 20 +-
.../ListPoliciesPreEvent.java} | 20 +-
.../ListPolicyInfosEvent.java} | 22 +-
.../ListPolicyInfosFailureEvent.java} | 22 +-
.../ListPolicyInfosForMetadataObjectEvent.java} | 32 +-
...tPolicyInfosForMetadataObjectFailureEvent.java} | 42 +-
.../ListPolicyInfosForMetadataObjectPreEvent.java} | 39 +-
.../ListPolicyInfosPreEvent.java} | 20 +-
.../{job/JobEvent.java => policy/PolicyEvent.java} | 23 +-
.../PolicyFailureEvent.java} | 20 +-
.../PolicyPreEvent.java} | 18 +-
.../gravitino/listener/api/info/PolicyInfo.java | 137 ++++
.../java/org/apache/gravitino/lock/TreeLock.java | 7 +-
.../org/apache/gravitino/lock/TreeLockNode.java | 2 +-
.../org/apache/gravitino/meta/TableEntity.java | 121 +++-
.../apache/gravitino/metrics/MetricsSystem.java | 4 +
.../gravitino/metrics/source/MetricsSource.java | 1 +
.../org/apache/gravitino/policy/PolicyManager.java | 2 +-
.../storage/relational/RelationalEntityStore.java | 39 +-
.../storage/relational/mapper/TableMetaMapper.java | 3 -
.../relational/mapper/TableVersionMapper.java | 50 ++
.../mapper/TableVersionSQLProviderFactory.java | 72 ++
.../storage/relational/mapper/TagMetaMapper.java | 9 +
.../mapper/TagMetaSQLProviderFactory.java | 9 +
.../provider/DefaultMapperPackageProvider.java | 4 +-
.../provider/base/TableMetaBaseSQLProvider.java | 84 ++-
.../provider/base/TableVersionBaseSQLProvider.java | 94 +++
.../provider/base/TagMetaBaseSQLProvider.java | 29 +
.../postgresql/TableVersionPostgreSQLProvider.java | 68 ++
.../gravitino/storage/relational/po/TablePO.java | 46 ++
.../relational/service/MetadataObjectService.java | 44 +-
.../relational/service/TableMetaService.java | 52 +-
.../storage/relational/service/TagMetaService.java | 7 +
.../storage/relational/utils/POConverters.java | 138 +++-
.../storage/relational/utils/SessionUtils.java | 12 +
.../java/org/apache/gravitino/tag/TagManager.java | 2 +-
.../apache/gravitino/utils/MetadataObjectUtil.java | 13 +-
.../apache/gravitino/utils/NameIdentifierUtil.java | 13 +-
.../catalog/TestManagedTableOperations.java | 755 +++++++++++++++++++++
.../gravitino/catalog/TestOperationDispatcher.java | 1 +
.../gravitino/hook/TestTableHookDispatcher.java | 7 +
.../gravitino/job/local/TestLocalJobExecutor.java | 27 +
.../listener/api/event/TestPolicyEvent.java | 689 +++++++++++++++++++
.../org/apache/gravitino/lock/TestTreeLock.java | 14 +
.../java/org/apache/gravitino/meta/TestEntity.java | 32 +-
.../metrics/TestExtractMetricNameAndLabel.java | 16 +
.../gravitino/storage/TestEntityStorage.java | 528 ++++++++++++++
.../apache/gravitino/storage/TestSQLScripts.java | 5 +
.../storage/relational/TestJDBCBackend.java | 122 ++++
.../storage/relational/utils/TestPOConverters.java | 21 +-
.../gravitino/utils/TestNameIdentifierUtil.java | 12 +-
dev/charts/gravitino/Chart.yaml | 4 +
.../gravitino/resources/config/gravitino.conf | 8 +-
.../gravitino/resources/scenarios/pg-values.yaml | 8 +-
dev/charts/gravitino/templates/_helpers.tpl | 9 +
dev/charts/gravitino/templates/deployment.yaml | 72 +-
dev/charts/gravitino/values.yaml | 38 ++
dev/docker/gravitino/gravitino-dependency.sh | 3 +-
.../iceberg-rest-server-dependency.sh | 2 +-
docs/gravitino-server-config.md | 2 +
docs/iceberg-rest-service.md | 21 +-
docs/lakehouse-iceberg-catalog.md | 20 +-
docs/security/access-control.md | 42 +-
.../connector/integration/test/FlinkEnvIT.java | 31 +-
gradle/libs.versions.toml | 6 +-
iceberg/iceberg-common/build.gradle.kts | 23 +-
.../common/utils/IcebergIdentifierUtils.java | 37 +-
.../common/utils/TestIcebergIdentifierUtils.java | 53 ++
iceberg/iceberg-rest-server/build.gradle.kts | 19 +
.../org/apache/gravitino/iceberg/RESTService.java | 34 +-
.../iceberg/server/GravitinoIcebergRESTServer.java | 10 +-
.../iceberg/service/CatalogWrapperForREST.java | 35 +-
.../service/IcebergCatalogWrapperManager.java | 2 +-
.../iceberg/service/IcebergExceptionMapper.java | 4 +-
...IcebergRestUtils.java => IcebergRESTUtils.java} | 10 +-
.../authorization/IcebergRESTServerContext.java | 71 ++
.../IcebergNamespaceEventDispatcher.java | 16 +-
.../dispatcher/IcebergNamespaceHookDispatcher.java | 159 +++++
.../IcebergNamespaceOperationExecutor.java | 31 +
.../service/dispatcher/IcebergOwnershipUtils.java | 90 +++
.../dispatcher/IcebergTableEventDispatcher.java | 18 +-
.../dispatcher/IcebergTableHookDispatcher.java | 172 +++++
.../dispatcher/IcebergTableOperationExecutor.java | 32 +-
.../dispatcher/IcebergViewEventDispatcher.java | 16 +-
.../iceberg/service/metrics/DummyMetricsStore.java | 3 +-
.../service/metrics/IcebergMetricsManager.java | 62 +-
.../service/metrics/IcebergMetricsStore.java | 6 +-
.../iceberg/service/metrics/JDBCMetricsStore.java | 279 ++++++++
.../provider/DynamicIcebergConfigProvider.java | 14 +
.../service/provider/IcebergConfigProvider.java | 9 +
.../service/rest/IcebergConfigOperations.java | 4 +-
.../service/rest/IcebergNamespaceOperations.java | 135 +++-
.../service/rest/IcebergTableOperations.java | 176 +++--
.../service/rest/IcebergTableRenameOperations.java | 22 +-
.../service/rest/IcebergViewOperations.java | 28 +-
.../service/rest/IcebergViewRenameOperations.java | 6 +-
.../api/event/IcebergCreateNamespaceEvent.java | 6 +-
.../event/IcebergCreateNamespaceFailureEvent.java | 4 +-
.../api/event/IcebergCreateTableEvent.java | 6 +-
.../api/event/IcebergCreateTableFailureEvent.java | 4 +-
.../listener/api/event/IcebergCreateViewEvent.java | 6 +-
.../api/event/IcebergCreateViewFailureEvent.java | 4 +-
.../api/event/IcebergLoadNamespaceEvent.java | 4 +-
.../listener/api/event/IcebergLoadTableEvent.java | 4 +-
.../listener/api/event/IcebergLoadViewEvent.java | 4 +-
.../api/event/IcebergRegisterTableEvent.java | 6 +-
.../event/IcebergRegisterTableFailureEvent.java | 4 +-
.../api/event/IcebergRenameTableEvent.java | 4 +-
.../listener/api/event/IcebergRenameViewEvent.java | 4 +-
.../api/event/IcebergReplaceViewEvent.java | 6 +-
.../api/event/IcebergReplaceViewFailureEvent.java | 4 +-
.../listener/api/event/IcebergRequestContext.java | 4 +-
.../api/event/IcebergUpdateNamespaceEvent.java | 6 +-
.../event/IcebergUpdateNamespaceFailureEvent.java | 4 +-
.../api/event/IcebergUpdateTableEvent.java | 6 +-
.../api/event/IcebergUpdateTableFailureEvent.java | 4 +-
.../annotations/IcebergAuthorizationMetadata.java | 30 +-
.../server/web/filter/BaseInterceptionService.java | 51 ++
...BaseMetadataAuthorizationMethodInterceptor.java | 182 +++++
...bergMetadataAuthorizationMethodInterceptor.java | 118 ++++
.../filter/IcebergRESTAuthInterceptionService.java | 51 ++
.../server/web/filter/LoadTableAuthzHandler.java | 124 ++++
.../server/web/filter/RenameTableAuthzHandler.java | 184 +++++
.../integration/test/IcebergAuthorizationIT.java | 326 +++++++++
.../test/IcebergNamespaceAuthorizationIT.java | 459 +++++++++++++
.../IcebergRESTCloudTokenAuthorizationBaseIT.java | 292 ++++++++
...ava => IcebergRESTGCSTokenAuthorizationIT.java} | 110 +--
.../test/IcebergRESTS3TokenAuthorizationIT.java | 114 ++++
.../test/IcebergTableAuthorizationIT.java | 683 +++++++++++++++++++
.../TestIcebergCatalogWrapperManagerForREST.java | 2 +
.../iceberg/service/TestIcebergRESTUtils.java | 23 +-
... => TestIcebergNamespaceOperationExecutor.java} | 80 +--
.../dispatcher/TestIcebergOwnershipUtils.java | 108 +++
.../iceberg/service/extension/HelloOperations.java | 4 +-
.../service/metrics/MemoryMetricsStore.java | 3 +-
.../service/metrics/TestIcebergMetricsManager.java | 13 +-
.../service/metrics/TestJdbcMetricsStore.java | 412 +++++++++++
.../iceberg/service/rest/IcebergRestTestUtil.java | 3 +
.../service/rest/TestIcebergTableOperations.java | 5 +
integration-test-common/build.gradle.kts | 3 +
.../gravitino/integration/test/MiniGravitino.java | 87 ++-
.../integration/test/MiniGravitinoContext.java | 11 +-
.../gravitino/integration/test/util/BaseIT.java | 46 +-
.../integration/test/util/TestDatabaseName.java | 1 +
{bundles => lance}/build.gradle.kts | 0
.../lance-common/build.gradle.kts | 39 +-
.../gravitino/lance/common/config/LanceConfig.java | 92 +++
.../lance/common/ops/LanceNamespaceBackend.java | 54 ++
.../lance/common/ops/LanceNamespaceOperations.java | 54 ++
.../lance/common/ops/LanceTableOperations.java | 97 +++
.../lance/common/ops/NamespaceWrapper.java | 76 +++
.../GravitinoLanceNameSpaceOperations.java | 435 ++++++++++++
.../gravitino/GravitinoLanceNamespaceWrapper.java | 119 ++++
.../gravitino/GravitinoLanceTableOperations.java | 293 ++++++++
.../ops/gravitino/LanceDataTypeConverter.java | 326 +++++++++
.../gravitino/lance/common/utils/ArrowUtils.java | 72 ++
.../lance/common/utils/LanceConstants.java | 35 +-
.../lance/common/utils/LancePropertiesUtils.java | 30 +-
.../lance/common/utils/SerializationUtils.java | 53 ++
.../lance/common/config/TestLanceConfig.java | 91 +++
.../ops/gravitino/TestLanceDataTypeConverter.java | 473 +++++++++++++
.../lance/common/utils/TestArrowUtils.java | 27 +-
lance/lance-rest-server/build.gradle.kts | 120 ++++
.../apache/gravitino/lance/LanceRESTService.java | 137 ++++
.../lance/service/LanceExceptionMapper.java | 88 +++
.../service/rest/LanceNamespaceOperations.java | 180 +++++
.../lance/service/rest/LanceTableOperations.java | 216 ++++++
...e.gravitino.auxiliary.GravitinoAuxiliaryService | 2 +-
.../lance/integration/test/LanceRESTServiceIT.java | 714 +++++++++++++++++++
.../service}/rest/ServletRequestFactoryBase.java | 2 +-
.../service/rest/TestLanceNamespaceOperations.java | 668 ++++++++++++++++++
.../src/test/resources/log4j2.properties | 2 +-
mcp-server/tests/unit/tools/__init__.py | 3 +
scripts/h2/iceberg-metrics-schema-1.1.0-h2.sql | 90 +++
.../{schema-1.0.0-h2.sql => schema-1.1.0-h2.sql} | 60 +-
scripts/h2/upgrade-1.0.0-to-1.1.0-h2.sql | 32 +
.../mysql/iceberg-metrics-schema-1.1.0-mysql.sql | 90 +++
...hema-1.0.0-mysql.sql => schema-1.1.0-mysql.sql} | 66 +-
scripts/mysql/upgrade-1.0.0-to-1.1.0-mysql.sql | 32 +
.../iceberg-metrics-schema-1.1.0-postgresql.sql | 169 +++++
...-postgresql.sql => schema-1.1.0-postgresql.sql} | 239 ++++---
.../upgrade-1.0.0-to-1.1.0-postgresql.sql | 43 ++
.../authentication/StaticSignKeyValidator.java | 28 +-
...aFilterHelper.java => MetadataAuthzHelper.java} | 30 +-
.../server/authorization/MetadataIdConverter.java | 3 +-
...onObjectType.java => AuthorizationRequest.java} | 15 +-
.../AuthorizationExpressionConstants.java | 26 +-
.../AuthorizationExpressionConverter.java | 18 +-
.../authorization/jcasbin/JcasbinAuthorizer.java | 12 +-
.../org/apache/gravitino/server/web/Utils.java | 17 +
.../apache/gravitino/server/TestServerConfig.java | 3 +-
.../authentication/TestStaticSignKeyValidator.java | 25 +
...terHelper.java => TestMetadataAuthzHelper.java} | 12 +-
.../web/filter/GravitinoInterceptionService.java | 223 ++----
.../gravitino/server/web/filter/ParameterUtil.java | 205 ++++++
.../AssociateTagAuthorizationExecutor.java | 115 ++++
.../authorization/AuthorizationExecutor.java | 14 +-
.../authorization/AuthorizeExecutorFactory.java | 49 ++
.../authorization/CommonAuthorizerExecutor.java | 53 ++
.../server/web/rest/CatalogOperations.java | 14 +-
.../server/web/rest/ExceptionHandlers.java | 2 +
.../server/web/rest/FilesetOperations.java | 4 +-
.../web/rest/MetadataObjectRoleOperations.java | 4 +-
.../web/rest/MetadataObjectTagOperations.java | 63 +-
.../server/web/rest/MetalakeOperations.java | 4 +-
.../gravitino/server/web/rest/ModelOperations.java | 8 +-
.../gravitino/server/web/rest/OwnerOperations.java | 3 +-
.../gravitino/server/web/rest/RoleOperations.java | 11 +-
.../server/web/rest/SchemaOperations.java | 4 +-
.../gravitino/server/web/rest/TableOperations.java | 4 +-
.../gravitino/server/web/rest/TagOperations.java | 85 ++-
.../gravitino/server/web/rest/TopicOperations.java | 4 +-
.../gravitino/server/web/rest/UserOperations.java | 6 +-
.../gravitino/server/web/ui/WebUIFilter.java | 7 +
.../server/web/rest/TestCatalogOperations.java | 34 +
.../web/rest/TestMetadataObjectTagOperations.java | 3 +-
.../server/web/rest/TestTagOperations.java | 3 +-
.../TestFilesetAuthorizationExpression.java | 1 +
.../TestTableAuthorizationExpression.java | 2 +
.../gravitino/server/web/ui/WebUIFilterTest.java | 53 ++
settings.gradle.kts | 3 +
.../spark/connector/catalog/BaseCatalog.java | 19 +
.../connector/integration/test/SparkEnvIT.java | 11 +-
.../test/authorization/SparkAuthorizationIT.java | 44 ++
spark-connector/v3.3/spark/build.gradle.kts | 1 +
spark-connector/v3.4/spark/build.gradle.kts | 1 +
spark-connector/v3.5/spark/build.gradle.kts | 1 +
.../lakehouse-iceberg/00011_table_statistics.sql | 14 +
.../lakehouse-iceberg/00011_table_statistics.txt | 13 +
.../trino-test-tools/download_jar.sh | 4 +-
.../trino/connector/GravitinoMetadata.java | 16 +-
.../catalog/jdbc/mysql/MySQLMetadataAdapter.java | 2 +
349 files changed, 20250 insertions(+), 1710 deletions(-)
copy catalogs/{catalog-jdbc-postgresql =>
catalog-generic-lakehouse}/build.gradle.kts (75%)
copy
catalogs/{catalog-lakehouse-iceberg/src/main/java/org/apache/gravitino/catalog/lakehouse/iceberg/IcebergCatalog.java
=>
catalog-generic-lakehouse/src/main/java/org/apache/gravitino/catalog/lakehouse/GenericLakehouseCatalog.java}
(58%)
copy core/src/test/java/org/apache/gravitino/TestCatalogCapabilities.java =>
catalogs/catalog-generic-lakehouse/src/main/java/org/apache/gravitino/catalog/lakehouse/GenericLakehouseCatalogCapability.java
(79%)
create mode 100644
catalogs/catalog-generic-lakehouse/src/main/java/org/apache/gravitino/catalog/lakehouse/GenericLakehouseCatalogOperations.java
copy
catalogs/{catalog-kafka/src/main/java/org/apache/gravitino/catalog/kafka/KafkaTopicPropertiesMetadata.java
=>
catalog-generic-lakehouse/src/main/java/org/apache/gravitino/catalog/lakehouse/GenericLakehouseCatalogPropertiesMetadata.java}
(58%)
copy
catalogs/{catalog-kafka/src/main/java/org/apache/gravitino/catalog/kafka/KafkaTopicPropertiesMetadata.java
=>
catalog-generic-lakehouse/src/main/java/org/apache/gravitino/catalog/lakehouse/GenericLakehouseSchemaPropertiesMetadata.java}
(60%)
create mode 100644
catalogs/catalog-generic-lakehouse/src/main/java/org/apache/gravitino/catalog/lakehouse/GenericLakehouseTablePropertiesMetadata.java
copy
core/src/main/java/org/apache/gravitino/listener/api/event/GetOwnerEvent.java
=>
catalogs/catalog-generic-lakehouse/src/main/java/org/apache/gravitino/catalog/lakehouse/LakehouseCatalogOperations.java
(52%)
copy
catalogs/{catalog-jdbc-starrocks/src/main/java/org/apache/gravitino/catalog/starrocks/StarRocksTablePropertiesMeta.java
=>
catalog-generic-lakehouse/src/main/java/org/apache/gravitino/catalog/lakehouse/LakehouseTableFormat.java}
(62%)
create mode 100644
catalogs/catalog-generic-lakehouse/src/main/java/org/apache/gravitino/catalog/lakehouse/lance/LanceCatalogOperations.java
copy
core/src/main/java/org/apache/gravitino/listener/api/event/GetOwnerFailureEvent.java
=>
catalogs/catalog-generic-lakehouse/src/main/java/org/apache/gravitino/catalog/lakehouse/utils/EntityConverter.java
(50%)
copy catalogs/{catalog-fileset =>
catalog-generic-lakehouse}/src/main/resources/META-INF/services/org.apache.gravitino.CatalogProvider
(92%)
copy web/web/.nvmrc =>
catalogs/catalog-generic-lakehouse/src/main/resources/generic-lakehouse.conf
(94%)
create mode 100644
catalogs/catalog-generic-lakehouse/src/test/java/org/apache/gravitino/catalog/lakehouse/TestGenericLakehouseCatalogOperations.java
create mode 100644
catalogs/catalog-generic-lakehouse/src/test/java/org/apache/gravitino/catalog/lakehouse/TestPropertiesMetadata.java
create mode 100644
catalogs/catalog-generic-lakehouse/src/test/java/org/apache/gravitino/catalog/lakehouse/integration/test/CatalogGenericLakehouseLanceIT.java
create mode 100644
catalogs/catalog-generic-lakehouse/src/test/java/org/apache/gravitino/catalog/lakehouse/utils/TestEntityConverter.java
rename clients/cli/src/test/java/org/apache/gravitino/cli/{TestFulllName.java
=> TestFullName.java} (94%)
create mode 100644
clients/client-java/src/test/java/org/apache/gravitino/client/integration/test/authorization/TagOperationsAuthorizationIT.java
copy clients/client-python/gravitino/dto/requests/{catalog_set_request.py =>
add_partitions_request.py} (63%)
copy clients/client-python/gravitino/dto/responses/{drop_response.py =>
partition_list_response.py} (58%)
copy clients/client-python/gravitino/dto/responses/{drop_response.py =>
partition_response.py} (66%)
create mode 100644 clients/client-python/tests/unittests/test_requests.py
create mode 100644
common/src/test/java/org/apache/gravitino/json/TestSerializer.java
create mode 100644 conf/gravitino-lance-rest-server.conf.template
create mode 100644
core/src/main/java/org/apache/gravitino/catalog/ManagedTableOperations.java
create mode 100644
core/src/main/java/org/apache/gravitino/connector/GenericColumn.java
create mode 100644
core/src/main/java/org/apache/gravitino/connector/GenericLakehouseColumn.java
create mode 100644
core/src/main/java/org/apache/gravitino/connector/GenericLakehouseTable.java
create mode 100644
core/src/main/java/org/apache/gravitino/connector/GenericTable.java
create mode 100644
core/src/main/java/org/apache/gravitino/hook/TagHookDispatcher.java
create mode 100644
core/src/main/java/org/apache/gravitino/listener/PolicyEventDispatcher.java
create mode 100644
core/src/main/java/org/apache/gravitino/listener/api/event/policy/AlterPolicyEvent.java
copy
core/src/main/java/org/apache/gravitino/listener/api/event/{job/ListJobsEvent.java
=> policy/AlterPolicyFailureEvent.java} (53%)
copy
core/src/main/java/org/apache/gravitino/listener/api/event/{job/ListJobTemplatesEvent.java
=> policy/AlterPolicyPreEvent.java} (56%)
create mode 100644
core/src/main/java/org/apache/gravitino/listener/api/event/policy/AssociatePoliciesForMetadataObjectEvent.java
create mode 100644
core/src/main/java/org/apache/gravitino/listener/api/event/policy/AssociatePoliciesForMetadataObjectFailureEvent.java
create mode 100644
core/src/main/java/org/apache/gravitino/listener/api/event/policy/AssociatePoliciesForMetadataObjectPreEvent.java
copy
core/src/main/java/org/apache/gravitino/listener/api/event/{AddPartitionEvent.java
=> policy/CreatePolicyEvent.java} (54%)
copy
core/src/main/java/org/apache/gravitino/listener/api/event/{job/ListJobsEvent.java
=> policy/CreatePolicyFailureEvent.java} (53%)
copy
core/src/main/java/org/apache/gravitino/listener/api/event/{job/ListJobTemplatesEvent.java
=> policy/CreatePolicyPreEvent.java} (53%)
copy
core/src/main/java/org/apache/gravitino/listener/api/event/{job/ListJobTemplatesEvent.java
=> policy/DeletePolicyEvent.java} (60%)
copy
core/src/main/java/org/apache/gravitino/listener/api/event/{ListPartitionEvent.java
=> policy/DeletePolicyFailureEvent.java} (65%)
copy
core/src/main/java/org/apache/gravitino/listener/api/event/{job/ListJobTemplatesEvent.java
=> policy/DeletePolicyPreEvent.java} (69%)
copy
core/src/main/java/org/apache/gravitino/listener/api/event/{job/ListJobTemplatesEvent.java
=> policy/DisablePolicyEvent.java} (69%)
copy
core/src/main/java/org/apache/gravitino/listener/api/event/{job/ListJobTemplatesEvent.java
=> policy/DisablePolicyFailureEvent.java} (64%)
copy
core/src/main/java/org/apache/gravitino/listener/api/event/{job/ListJobTemplatesEvent.java
=> policy/DisablePolicyPreEvent.java} (69%)
copy
core/src/main/java/org/apache/gravitino/listener/api/event/{job/ListJobTemplatesEvent.java
=> policy/EnablePolicyEvent.java} (69%)
copy
core/src/main/java/org/apache/gravitino/listener/api/event/{job/ListJobTemplatesEvent.java
=> policy/EnablePolicyFailureEvent.java} (65%)
copy
core/src/main/java/org/apache/gravitino/listener/api/event/{job/ListJobTemplatesEvent.java
=> policy/EnablePolicyPreEvent.java} (69%)
copy
core/src/main/java/org/apache/gravitino/listener/api/event/{job/ListJobTemplatesEvent.java
=> policy/GetPolicyEvent.java} (57%)
copy
core/src/main/java/org/apache/gravitino/listener/api/event/{job/ListJobTemplatesEvent.java
=> policy/GetPolicyFailureEvent.java} (60%)
copy
core/src/main/java/org/apache/gravitino/listener/api/event/{GetTagForMetadataObjectEvent.java
=> policy/GetPolicyForMetadataObjectEvent.java} (51%)
create mode 100644
core/src/main/java/org/apache/gravitino/listener/api/event/policy/GetPolicyForMetadataObjectFailureEvent.java
copy
core/src/main/java/org/apache/gravitino/listener/api/event/{GetTagForMetadataObjectEvent.java
=> policy/GetPolicyForMetadataObjectPreEvent.java} (51%)
copy
core/src/main/java/org/apache/gravitino/listener/api/event/{job/ListJobTemplatesEvent.java
=> policy/GetPolicyPreEvent.java} (69%)
copy
core/src/main/java/org/apache/gravitino/listener/api/event/{job/ListJobTemplatesEvent.java
=> policy/ListMetadataObjectsForPolicyEvent.java} (67%)
copy
core/src/main/java/org/apache/gravitino/listener/api/event/{ListPartitionNamesFailureEvent.java
=> policy/ListMetadataObjectsForPolicyFailureEvent.java} (62%)
copy
core/src/main/java/org/apache/gravitino/listener/api/event/{job/ListJobTemplatesEvent.java
=> policy/ListMetadataObjectsForPolicyPreEvent.java} (67%)
copy
core/src/main/java/org/apache/gravitino/listener/api/event/{job/GetJobPreEvent.java
=> policy/ListPoliciesEvent.java} (65%)
copy
core/src/main/java/org/apache/gravitino/listener/api/event/{job/DeleteJobTemplatePreEvent.java
=> policy/ListPoliciesFailureEvent.java} (60%)
copy
core/src/main/java/org/apache/gravitino/listener/api/event/{job/CancelJobPreEvent.java
=> policy/ListPoliciesPreEvent.java} (65%)
copy
core/src/main/java/org/apache/gravitino/listener/api/event/{job/GetJobPreEvent.java
=> policy/ListPolicyInfosEvent.java} (64%)
copy
core/src/main/java/org/apache/gravitino/listener/api/event/{job/GetJobPreEvent.java
=> policy/ListPolicyInfosFailureEvent.java} (59%)
copy
core/src/main/java/org/apache/gravitino/listener/api/event/{ListTagsInfoForMetadataObjectEvent.java
=> policy/ListPolicyInfosForMetadataObjectEvent.java} (60%)
copy
core/src/main/java/org/apache/gravitino/listener/api/event/{GetTagForMetadataObjectEvent.java
=> policy/ListPolicyInfosForMetadataObjectFailureEvent.java} (52%)
copy
core/src/main/java/org/apache/gravitino/listener/api/event/{GetTagForMetadataObjectEvent.java
=> policy/ListPolicyInfosForMetadataObjectPreEvent.java} (57%)
copy
core/src/main/java/org/apache/gravitino/listener/api/event/{job/CancelJobPreEvent.java
=> policy/ListPolicyInfosPreEvent.java} (64%)
copy
core/src/main/java/org/apache/gravitino/listener/api/event/{job/JobEvent.java
=> policy/PolicyEvent.java} (65%)
copy
core/src/main/java/org/apache/gravitino/listener/api/event/{job/JobFailureEvent.java
=> policy/PolicyFailureEvent.java} (62%)
copy
core/src/main/java/org/apache/gravitino/listener/api/event/{job/JobPreEvent.java
=> policy/PolicyPreEvent.java} (67%)
create mode 100644
core/src/main/java/org/apache/gravitino/listener/api/info/PolicyInfo.java
create mode 100644
core/src/main/java/org/apache/gravitino/storage/relational/mapper/TableVersionMapper.java
create mode 100644
core/src/main/java/org/apache/gravitino/storage/relational/mapper/TableVersionSQLProviderFactory.java
create mode 100644
core/src/main/java/org/apache/gravitino/storage/relational/mapper/provider/base/TableVersionBaseSQLProvider.java
create mode 100644
core/src/main/java/org/apache/gravitino/storage/relational/mapper/provider/postgresql/TableVersionPostgreSQLProvider.java
create mode 100644
core/src/test/java/org/apache/gravitino/catalog/TestManagedTableOperations.java
create mode 100644
core/src/test/java/org/apache/gravitino/listener/api/event/TestPolicyEvent.java
copy
bundles/aliyun/src/main/resources/META-INF/services/org.apache.gravitino.catalog.hadoop.fs.FileSystemProvider
=> dev/charts/gravitino/resources/scenarios/pg-values.yaml (73%)
copy
core/src/main/java/org/apache/gravitino/listener/api/event/GetPartitionPreEvent.java
=>
iceberg/iceberg-common/src/main/java/org/apache/gravitino/iceberg/common/utils/IcebergIdentifierUtils.java
(55%)
create mode 100644
iceberg/iceberg-common/src/test/java/org/apache/gravitino/iceberg/common/utils/TestIcebergIdentifierUtils.java
rename
iceberg/iceberg-rest-server/src/main/java/org/apache/gravitino/iceberg/service/{IcebergRestUtils.java
=> IcebergRESTUtils.java} (94%)
create mode 100644
iceberg/iceberg-rest-server/src/main/java/org/apache/gravitino/iceberg/service/authorization/IcebergRESTServerContext.java
create mode 100644
iceberg/iceberg-rest-server/src/main/java/org/apache/gravitino/iceberg/service/dispatcher/IcebergNamespaceHookDispatcher.java
create mode 100644
iceberg/iceberg-rest-server/src/main/java/org/apache/gravitino/iceberg/service/dispatcher/IcebergOwnershipUtils.java
create mode 100644
iceberg/iceberg-rest-server/src/main/java/org/apache/gravitino/iceberg/service/dispatcher/IcebergTableHookDispatcher.java
create mode 100644
iceberg/iceberg-rest-server/src/main/java/org/apache/gravitino/iceberg/service/metrics/JDBCMetricsStore.java
copy
core/src/main/java/org/apache/gravitino/listener/api/event/DropMetalakePreEvent.java
=>
iceberg/iceberg-rest-server/src/main/java/org/apache/gravitino/server/authorization/annotations/IcebergAuthorizationMetadata.java
(55%)
create mode 100644
iceberg/iceberg-rest-server/src/main/java/org/apache/gravitino/server/web/filter/BaseInterceptionService.java
create mode 100644
iceberg/iceberg-rest-server/src/main/java/org/apache/gravitino/server/web/filter/BaseMetadataAuthorizationMethodInterceptor.java
create mode 100644
iceberg/iceberg-rest-server/src/main/java/org/apache/gravitino/server/web/filter/IcebergMetadataAuthorizationMethodInterceptor.java
create mode 100644
iceberg/iceberg-rest-server/src/main/java/org/apache/gravitino/server/web/filter/IcebergRESTAuthInterceptionService.java
create mode 100644
iceberg/iceberg-rest-server/src/main/java/org/apache/gravitino/server/web/filter/LoadTableAuthzHandler.java
create mode 100644
iceberg/iceberg-rest-server/src/main/java/org/apache/gravitino/server/web/filter/RenameTableAuthzHandler.java
create mode 100644
iceberg/iceberg-rest-server/src/test/java/org/apache/gravitino/iceberg/integration/test/IcebergAuthorizationIT.java
create mode 100644
iceberg/iceberg-rest-server/src/test/java/org/apache/gravitino/iceberg/integration/test/IcebergNamespaceAuthorizationIT.java
create mode 100644
iceberg/iceberg-rest-server/src/test/java/org/apache/gravitino/iceberg/integration/test/IcebergRESTCloudTokenAuthorizationBaseIT.java
copy
iceberg/iceberg-rest-server/src/test/java/org/apache/gravitino/iceberg/integration/test/{IcebergRESTGCSIT.java
=> IcebergRESTGCSTokenAuthorizationIT.java} (50%)
create mode 100644
iceberg/iceberg-rest-server/src/test/java/org/apache/gravitino/iceberg/integration/test/IcebergRESTS3TokenAuthorizationIT.java
create mode 100644
iceberg/iceberg-rest-server/src/test/java/org/apache/gravitino/iceberg/integration/test/IcebergTableAuthorizationIT.java
copy
iceberg/iceberg-rest-server/src/test/java/org/apache/gravitino/iceberg/service/dispatcher/{TestIcebergTableOperationExecutor.java
=> TestIcebergNamespaceOperationExecutor.java} (55%)
create mode 100644
iceberg/iceberg-rest-server/src/test/java/org/apache/gravitino/iceberg/service/dispatcher/TestIcebergOwnershipUtils.java
create mode 100644
iceberg/iceberg-rest-server/src/test/java/org/apache/gravitino/iceberg/service/metrics/TestJdbcMetricsStore.java
copy {bundles => lance}/build.gradle.kts (100%)
copy
core/src/main/java/org/apache/gravitino/listener/api/event/SetOwnerPreEvent.java
=> lance/lance-common/build.gradle.kts (54%)
create mode 100644
lance/lance-common/src/main/java/org/apache/gravitino/lance/common/config/LanceConfig.java
create mode 100644
lance/lance-common/src/main/java/org/apache/gravitino/lance/common/ops/LanceNamespaceBackend.java
create mode 100644
lance/lance-common/src/main/java/org/apache/gravitino/lance/common/ops/LanceNamespaceOperations.java
create mode 100644
lance/lance-common/src/main/java/org/apache/gravitino/lance/common/ops/LanceTableOperations.java
create mode 100644
lance/lance-common/src/main/java/org/apache/gravitino/lance/common/ops/NamespaceWrapper.java
create mode 100644
lance/lance-common/src/main/java/org/apache/gravitino/lance/common/ops/gravitino/GravitinoLanceNameSpaceOperations.java
create mode 100644
lance/lance-common/src/main/java/org/apache/gravitino/lance/common/ops/gravitino/GravitinoLanceNamespaceWrapper.java
create mode 100644
lance/lance-common/src/main/java/org/apache/gravitino/lance/common/ops/gravitino/GravitinoLanceTableOperations.java
create mode 100644
lance/lance-common/src/main/java/org/apache/gravitino/lance/common/ops/gravitino/LanceDataTypeConverter.java
create mode 100644
lance/lance-common/src/main/java/org/apache/gravitino/lance/common/utils/ArrowUtils.java
copy
api/src/main/java/org/apache/gravitino/rel/expressions/literals/Literal.java =>
lance/lance-common/src/main/java/org/apache/gravitino/lance/common/utils/LanceConstants.java
(57%)
copy
authorizations/authorization-common/src/main/java/org/apache/gravitino/authorization/common/AuthorizationProperties.java
=>
lance/lance-common/src/main/java/org/apache/gravitino/lance/common/utils/LancePropertiesUtils.java
(54%)
create mode 100644
lance/lance-common/src/main/java/org/apache/gravitino/lance/common/utils/SerializationUtils.java
create mode 100644
lance/lance-common/src/test/java/org/apache/gravitino/lance/common/config/TestLanceConfig.java
create mode 100644
lance/lance-common/src/test/java/org/apache/gravitino/lance/common/ops/gravitino/TestLanceDataTypeConverter.java
copy
catalogs/catalog-lakehouse-hudi/src/test/java/org/apache/gravitino/catalog/lakehouse/hudi/backend/hms/TestHudiHMSBackend.java
=>
lance/lance-common/src/test/java/org/apache/gravitino/lance/common/utils/TestArrowUtils.java
(56%)
create mode 100644 lance/lance-rest-server/build.gradle.kts
create mode 100644
lance/lance-rest-server/src/main/java/org/apache/gravitino/lance/LanceRESTService.java
create mode 100644
lance/lance-rest-server/src/main/java/org/apache/gravitino/lance/service/LanceExceptionMapper.java
create mode 100644
lance/lance-rest-server/src/main/java/org/apache/gravitino/lance/service/rest/LanceNamespaceOperations.java
create mode 100644
lance/lance-rest-server/src/main/java/org/apache/gravitino/lance/service/rest/LanceTableOperations.java
copy {iceberg/iceberg-rest-server =>
lance/lance-rest-server}/src/main/resources/META-INF/services/org.apache.gravitino.auxiliary.GravitinoAuxiliaryService
(94%)
create mode 100644
lance/lance-rest-server/src/test/java/org/apache/gravitino/lance/integration/test/LanceRESTServiceIT.java
copy {server/src/test/java/org/apache/gravitino/server/web =>
lance/lance-rest-server/src/test/java/org/apache/gravitino/lance/service}/rest/ServletRequestFactoryBase.java
(96%)
create mode 100644
lance/lance-rest-server/src/test/java/org/apache/gravitino/lance/service/rest/TestLanceNamespaceOperations.java
copy {catalogs/catalog-hive =>
lance/lance-rest-server}/src/test/resources/log4j2.properties (96%)
create mode 100644 scripts/h2/iceberg-metrics-schema-1.1.0-h2.sql
copy scripts/h2/{schema-1.0.0-h2.sql => schema-1.1.0-h2.sql} (94%)
create mode 100644 scripts/h2/upgrade-1.0.0-to-1.1.0-h2.sql
create mode 100644 scripts/mysql/iceberg-metrics-schema-1.1.0-mysql.sql
copy scripts/mysql/{schema-1.0.0-mysql.sql => schema-1.1.0-mysql.sql} (87%)
create mode 100644 scripts/mysql/upgrade-1.0.0-to-1.1.0-mysql.sql
create mode 100644
scripts/postgresql/iceberg-metrics-schema-1.1.0-postgresql.sql
copy scripts/postgresql/{schema-1.0.0-postgresql.sql =>
schema-1.1.0-postgresql.sql} (76%)
create mode 100644 scripts/postgresql/upgrade-1.0.0-to-1.1.0-postgresql.sql
rename
server-common/src/main/java/org/apache/gravitino/server/authorization/{MetadataFilterHelper.java
=> MetadataAuthzHelper.java} (93%)
copy
server-common/src/main/java/org/apache/gravitino/server/authorization/annotations/{AuthorizationObjectType.java
=> AuthorizationRequest.java} (85%)
rename
server-common/src/test/java/org/apache/gravitino/server/authorization/{TestMetadataFilterHelper.java
=> TestMetadataAuthzHelper.java} (95%)
create mode 100644
server/src/main/java/org/apache/gravitino/server/web/filter/ParameterUtil.java
create mode 100644
server/src/main/java/org/apache/gravitino/server/web/filter/authorization/AssociateTagAuthorizationExecutor.java
copy web/web/src/lib/styles/globals.css =>
server/src/main/java/org/apache/gravitino/server/web/filter/authorization/AuthorizationExecutor.java
(85%)
create mode 100644
server/src/main/java/org/apache/gravitino/server/web/filter/authorization/AuthorizeExecutorFactory.java
create mode 100644
server/src/main/java/org/apache/gravitino/server/web/filter/authorization/CommonAuthorizerExecutor.java
create mode 100644
server/src/test/java/org/apache/gravitino/server/web/ui/WebUIFilterTest.java
create mode 100644
trino-connector/integration-test/src/test/resources/trino-ci-testset/testsets/lakehouse-iceberg/00011_table_statistics.sql
create mode 100644
trino-connector/integration-test/src/test/resources/trino-ci-testset/testsets/lakehouse-iceberg/00011_table_statistics.txt