LiebingYu commented on code in PR #1901:
URL: https://github.com/apache/fluss/pull/1901#discussion_r2477449981
##########
fluss-common/src/main/java/org/apache/fluss/lake/lakestorage/LakeCatalog.java:
##########
@@ -39,23 +40,40 @@ public interface LakeCatalog extends AutoCloseable {
*
* @param tablePath path of the table to be created
* @param tableDescriptor The descriptor of the table to be created
+ * @param context contextual information needed for create table
* @throws TableAlreadyExistException if the table already exists
*/
- void createTable(TablePath tablePath, TableDescriptor tableDescriptor)
+ void createTable(TablePath tablePath, TableDescriptor tableDescriptor,
Context context)
throws TableAlreadyExistException;
/**
* Alter a table in lake.
*
* @param tablePath path of the table to be altered
* @param tableChanges The changes to be applied to the table
+ * @param context contextual information needed for alter table
* @throws TableNotExistException if the table not exists
*/
- void alterTable(TablePath tablePath, List<TableChange> tableChanges)
+ void alterTable(TablePath tablePath, List<TableChange> tableChanges,
Context context)
throws TableNotExistException;
@Override
default void close() throws Exception {
// default do nothing
}
+
+ /**
+ * Contextual information for lake catalog methods that modify metadata in
an external data
+ * lake. It can be used to:
+ *
+ * <ul>
+ * <li>Access the fluss principal currently accessing the catalog.
+ * </ul>
+ */
+ @PublicEvolving
Review Comment:
fixed
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
