[lake] LakeCatalog supports multi-tenancy

[LiebingYu]

Purpose

Linked issue: close #1890

Brief change log

Tests

API and Format

Documentation

[luoyuxia]

@LiebingYu Only one minor comment.

[Copilot]

Pull Request Overview

This pull request adds a Context interface to the LakeCatalog API to provide contextual information (specifically the FlussPrincipal) to lake catalog operations. This enables lake catalog implementations to access user identity information during table creation and modification.

• Added a new Context interface to LakeCatalog with a method to retrieve the FlussPrincipal
• Updated createTable and alterTable method signatures across all LakeCatalog implementations to accept the new Context parameter
• Created DefaultLakeCatalogContext in CoordinatorService to supply the principal from the current session

Reviewed Changes

Copilot reviewed 12 out of 12 changed files in this pull request and generated 6 comments.

Show a summary per file

File	Description
fluss-common/src/main/java/org/apache/fluss/lake/lakestorage/LakeCatalog.java	Adds Context interface and updates createTable/alterTable signatures to include Context parameter
fluss-common/src/main/java/org/apache/fluss/lake/lakestorage/PluginLakeStorageWrapper.java	Updates ClassLoaderFixingLakeCatalog wrapper to pass Context parameter through
fluss-common/src/test/java/org/apache/fluss/lake/lakestorage/LakeStorageTest.java	Updates test implementation to include Context parameter in method signatures
fluss-common/src/test/java/org/apache/fluss/lake/lakestorage/TestingLakeCatalogContext.java	Adds testing implementation of Context interface
fluss-lake/fluss-lake-iceberg/src/main/java/org/apache/fluss/lake/iceberg/IcebergLakeCatalog.java	Updates Iceberg implementation to accept Context parameter
fluss-lake/fluss-lake-iceberg/src/test/java/org/apache/fluss/lake/iceberg/IcebergLakeCatalogTest.java	Updates test calls to pass TestingLakeCatalogContext
fluss-lake/fluss-lake-lance/src/main/java/org/apache/fluss/lake/lance/LanceLakeCatalog.java	Updates Lance implementation to accept Context parameter
fluss-lake/fluss-lake-paimon/src/main/java/org/apache/fluss/lake/paimon/PaimonLakeCatalog.java	Updates Paimon implementation to accept Context parameter
fluss-lake/fluss-lake-paimon/src/test/java/org/apache/fluss/lake/paimon/PaimonLakeCatalogTest.java	Updates test calls to pass TestingLakeCatalogContext
fluss-server/src/main/java/org/apache/fluss/server/coordinator/CoordinatorService.java	Adds DefaultLakeCatalogContext implementation and passes it to lake catalog operations
fluss-server/src/main/java/org/apache/fluss/server/coordinator/MetadataManager.java	Updates method signatures to accept and pass through lakeCatalogContext
fluss-server/src/test/java/org/apache/fluss/server/lakehouse/TestingPaimonStoragePlugin.java	Updates test implementation to include Context parameter

---

💡 Add Copilot custom instructions for smarter, more guided reviews. Learn how to get started.