(fluss-rust) branch main updated: chore: fix mut schema builder public api (#420)

[yuxia]

This is an automated email from the ASF dual-hosted git repository.

yuxia pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/fluss-rust.git


The following commit(s) were added to refs/heads/main by this push:
     new 5718d20  chore: fix mut schema builder public api (#420)
5718d20 is described below

commit 5718d206b86416eac481f745952db5c048bd7349
Author: Anton Borisov <148864665+fresh-borz...@users.noreply.github.com>
AuthorDate: Tue Mar 3 13:35:16 2026 +0000

    chore: fix mut schema builder public api (#420)
---
 crates/examples/Cargo.toml         | 2 +-
 crates/fluss/src/metadata/table.rs | 6 +++---
 crates/fluss/src/test_utils.rs     | 2 +-
 3 files changed, 5 insertions(+), 5 deletions(-)

diff --git a/crates/examples/Cargo.toml b/crates/examples/Cargo.toml
index cce6faf..26251cc 100644
--- a/crates/examples/Cargo.toml
+++ b/crates/examples/Cargo.toml
@@ -37,4 +37,4 @@ path = "src/example_kv_table.rs"
 
 [[example]]
 name = "example-partitioned-upsert-lookup"
-path = "src/example_partitioned_kv_table.rs"
\ No newline at end of file
+path = "src/example_partitioned_kv_table.rs"
diff --git a/crates/fluss/src/metadata/table.rs 
b/crates/fluss/src/metadata/table.rs
index 7f0d2e2..dba9a52 100644
--- a/crates/fluss/src/metadata/table.rs
+++ b/crates/fluss/src/metadata/table.rs
@@ -234,8 +234,8 @@ impl SchemaBuilder {
         Ok(self)
     }
 
-    pub fn build(&mut self) -> Result<Schema> {
-        let columns = Self::normalize_columns(&mut self.columns, 
self.primary_key.as_ref())?;
+    pub fn build(&self) -> Result<Schema> {
+        let columns = Self::normalize_columns(&self.columns, 
self.primary_key.as_ref())?;
 
         let column_names: HashSet<_> = columns.iter().map(|c| 
&c.name).collect();
         for auto_inc_col in &self.auto_increment_col_names {
@@ -266,7 +266,7 @@ impl SchemaBuilder {
     }
 
     fn normalize_columns(
-        columns: &mut [Column],
+        columns: &[Column],
         primary_key: Option<&PrimaryKey>,
     ) -> Result<Vec<Column>> {
         let names: Vec<_> = columns.iter().map(|c| &c.name).collect();
diff --git a/crates/fluss/src/test_utils.rs b/crates/fluss/src/test_utils.rs
index 752d422..47bb2ea 100644
--- a/crates/fluss/src/test_utils.rs
+++ b/crates/fluss/src/test_utils.rs
@@ -25,7 +25,7 @@ use std::sync::Arc;
 
 pub(crate) fn build_table_info(table_path: TablePath, table_id: i64, buckets: 
i32) -> TableInfo {
     let row_type = DataTypes::row(vec![DataField::new("id", DataTypes::int(), 
None)]);
-    let mut schema_builder = Schema::builder().with_row_type(&row_type);
+    let schema_builder = Schema::builder().with_row_type(&row_type);
     let schema = schema_builder.build().expect("schema build");
     let table_descriptor = TableDescriptor::builder()
         .schema(schema)