[server] Rename RPC AlterTablePropertiesRequest to AlterTableRequest for future extensibility (#1766)

Author: gyang94

fluss-client/src/main/java/org/apache/fluss/client/admin/FlussAdmin.java

@@ -42,7 +42,7 @@
 import org.apache.fluss.rpc.gateway.AdminGateway;
 import org.apache.fluss.rpc.gateway.AdminReadOnlyGateway;
 import org.apache.fluss.rpc.gateway.TabletServerGateway;
-import org.apache.fluss.rpc.messages.AlterTablePropertiesRequest;
+import org.apache.fluss.rpc.messages.AlterTableRequest;
 import org.apache.fluss.rpc.messages.CreateAclsRequest;
 import org.apache.fluss.rpc.messages.CreateDatabaseRequest;
 import org.apache.fluss.rpc.messages.CreateTableRequest;
@@ -243,7 +243,7 @@ public CompletableFuture<Void> createTable(
     public CompletableFuture<Void> alterTable(
             TablePath tablePath, List<TableChange> tableChanges, boolean ignoreIfNotExists) {
         tablePath.validate();
-        AlterTablePropertiesRequest request = new AlterTablePropertiesRequest();
+        AlterTableRequest request = new AlterTableRequest();
 
         List<PbAlterConfig> pbFlussTableChanges =
                 tableChanges.stream()
@@ -255,7 +255,7 @@ public CompletableFuture<Void> alterTable(
                 .setTablePath()
                 .setDatabaseName(tablePath.getDatabaseName())
                 .setTableName(tablePath.getTableName());
-        return gateway.alterTableProperties(request).thenApply(r -> null);
+        return gateway.alterTable(request).thenApply(r -> null);
     }
 
     @Override

fluss-rpc/src/main/java/org/apache/fluss/rpc/gateway/AdminGateway.java

@@ -17,8 +17,8 @@
 
 package org.apache.fluss.rpc.gateway;
 
-import org.apache.fluss.rpc.messages.AlterTablePropertiesRequest;
-import org.apache.fluss.rpc.messages.AlterTablePropertiesResponse;
+import org.apache.fluss.rpc.messages.AlterTableRequest;
+import org.apache.fluss.rpc.messages.AlterTableResponse;
 import org.apache.fluss.rpc.messages.CreateAclsRequest;
 import org.apache.fluss.rpc.messages.CreateAclsResponse;
 import org.apache.fluss.rpc.messages.CreateDatabaseRequest;
@@ -69,11 +69,10 @@ public interface AdminGateway extends AdminReadOnlyGateway {
     /**
      * Alter a table.
      *
-     * @param request the request to alter the configs of a table.
+     * @param request the request to alter a table.
      */
     @RPC(api = ApiKeys.ALTER_TABLE_PROPERTIES)
-    CompletableFuture<AlterTablePropertiesResponse> alterTableProperties(
-            AlterTablePropertiesRequest request);
+    CompletableFuture<AlterTableResponse> alterTable(AlterTableRequest request);
 
     /**
      * Drop a table.

fluss-rpc/src/main/proto/FlussApi.proto

@@ -109,7 +109,7 @@ message CreateTableResponse {
 }
 
 // alter table request and response
-message AlterTablePropertiesRequest {
+message AlterTableRequest {
   required PbTablePath table_path = 1;
   required bool ignore_if_not_exists = 2;
   repeated PbAlterConfig config_changes = 3;
@@ -122,7 +122,7 @@ message PbAlterConfig {
   required int32 op_type = 3; // SET=0, DELETE=1, APPEND=2, SUBTRACT=3
 }
 
-message AlterTablePropertiesResponse {
+message AlterTableResponse {
 }
 
 

fluss-server/src/main/java/org/apache/fluss/server/coordinator/CoordinatorService.java

@@ -41,8 +41,8 @@
 import org.apache.fluss.rpc.gateway.CoordinatorGateway;
 import org.apache.fluss.rpc.messages.AdjustIsrRequest;
 import org.apache.fluss.rpc.messages.AdjustIsrResponse;
-import org.apache.fluss.rpc.messages.AlterTablePropertiesRequest;
-import org.apache.fluss.rpc.messages.AlterTablePropertiesResponse;
+import org.apache.fluss.rpc.messages.AlterTableRequest;
+import org.apache.fluss.rpc.messages.AlterTableResponse;
 import org.apache.fluss.rpc.messages.CommitKvSnapshotRequest;
 import org.apache.fluss.rpc.messages.CommitKvSnapshotResponse;
 import org.apache.fluss.rpc.messages.CommitLakeTableSnapshotRequest;
@@ -293,8 +293,7 @@ public CompletableFuture<CreateTableResponse> createTable(CreateTableRequest req
     }
 
     @Override
-    public CompletableFuture<AlterTablePropertiesResponse> alterTableProperties(
-            AlterTablePropertiesRequest request) {
+    public CompletableFuture<AlterTableResponse> alterTable(AlterTableRequest request) {
         TablePath tablePath = toTablePath(request.getTablePath());
         tablePath.validate();
         if (authorizer != null) {
@@ -313,7 +312,7 @@ public CompletableFuture<AlterTablePropertiesResponse> alterTableProperties(
                 dataLakeFormat,
                 lakeTableTieringManager);
 
-        return CompletableFuture.completedFuture(new AlterTablePropertiesResponse());
+        return CompletableFuture.completedFuture(new AlterTableResponse());
     }
 
     public static TablePropertyChanges toTablePropertyChanges(List<TableChange> tableChanges) {

fluss-server/src/test/java/org/apache/fluss/server/coordinator/TableManagerITCase.java

@@ -88,7 +88,7 @@
 import java.util.stream.Collectors;
 
 import static org.apache.fluss.config.ConfigOptions.DEFAULT_LISTENER_NAME;
-import static org.apache.fluss.server.testutils.RpcMessageTestUtils.newAlterTablePropertiesRequest;
+import static org.apache.fluss.server.testutils.RpcMessageTestUtils.newAlterTableRequest;
 import static org.apache.fluss.server.testutils.RpcMessageTestUtils.newCreateDatabaseRequest;
 import static org.apache.fluss.server.testutils.RpcMessageTestUtils.newCreateTableRequest;
 import static org.apache.fluss.server.testutils.RpcMessageTestUtils.newDatabaseExistsRequest;
@@ -294,8 +294,8 @@ void testTableManagement(boolean isCoordinatorServer) throws Exception {
         List<String> resetProperties = new ArrayList<>();
 
         adminGateway
-                .alterTableProperties(
-                        newAlterTablePropertiesRequest(
+                .alterTable(
+                        newAlterTableRequest(
                                 tablePath,
                                 alterTableProperties(setProperties, resetProperties),
                                 false))

fluss-server/src/test/java/org/apache/fluss/server/coordinator/TestCoordinatorGateway.java

@@ -23,8 +23,8 @@
 import org.apache.fluss.rpc.gateway.CoordinatorGateway;
 import org.apache.fluss.rpc.messages.AdjustIsrRequest;
 import org.apache.fluss.rpc.messages.AdjustIsrResponse;
-import org.apache.fluss.rpc.messages.AlterTablePropertiesRequest;
-import org.apache.fluss.rpc.messages.AlterTablePropertiesResponse;
+import org.apache.fluss.rpc.messages.AlterTableRequest;
+import org.apache.fluss.rpc.messages.AlterTableResponse;
 import org.apache.fluss.rpc.messages.ApiVersionsRequest;
 import org.apache.fluss.rpc.messages.ApiVersionsResponse;
 import org.apache.fluss.rpc.messages.CommitKvSnapshotRequest;
@@ -142,8 +142,7 @@ public CompletableFuture<CreateTableResponse> createTable(CreateTableRequest req
     }
 
     @Override
-    public CompletableFuture<AlterTablePropertiesResponse> alterTableProperties(
-            AlterTablePropertiesRequest request) {
+    public CompletableFuture<AlterTableResponse> alterTable(AlterTableRequest request) {
         throw new UnsupportedOperationException();
     }
 

fluss-server/src/test/java/org/apache/fluss/server/testutils/RpcMessageTestUtils.java

@@ -27,7 +27,7 @@
 import org.apache.fluss.record.MemoryLogRecords;
 import org.apache.fluss.record.bytesview.MemorySegmentBytesView;
 import org.apache.fluss.rpc.gateway.CoordinatorGateway;
-import org.apache.fluss.rpc.messages.AlterTablePropertiesRequest;
+import org.apache.fluss.rpc.messages.AlterTableRequest;
 import org.apache.fluss.rpc.messages.CreateDatabaseRequest;
 import org.apache.fluss.rpc.messages.CreatePartitionRequest;
 import org.apache.fluss.rpc.messages.CreateTableRequest;
@@ -141,9 +141,9 @@ public static CreateTableRequest newCreateTableRequest(
         return createTableRequest;
     }
 
-    public static AlterTablePropertiesRequest newAlterTablePropertiesRequest(
+    public static AlterTableRequest newAlterTableRequest(
             TablePath tablePath, List<PbAlterConfig> alterConfigs, boolean ignoreIfExists) {
-        AlterTablePropertiesRequest request = new AlterTablePropertiesRequest();
+        AlterTableRequest request = new AlterTableRequest();
         request.addAllConfigChanges(alterConfigs)
                 .setIgnoreIfNotExists(ignoreIfExists)
                 .setTablePath()