address format

Author: vladson

crates/catalog/hms/src/catalog.rs

@@ -753,9 +753,9 @@ impl Catalog for HmsCatalog {
             let metadata_location = get_metadata_location(&hive_table.parameters)?;
             let env_context = Self::build_environment_context(&metadata_location);
 
-            let (staged_table, new_hive_table) =
-                self.apply_and_prepare_update(commit, &db_name, &tbl_name, &hive_table)
-                    .await?;
+            let (staged_table, new_hive_table) = self
+                .apply_and_prepare_update(commit, &db_name, &tbl_name, &hive_table)
+                .await?;
 
             self.client
                 .0
@@ -781,9 +781,9 @@ impl Catalog for HmsCatalog {
                 .map(from_thrift_exception)
                 .map_err(from_thrift_error)??;
 
-            let (staged_table, new_hive_table) =
-                self.apply_and_prepare_update(commit, &db_name, &tbl_name, &hive_table)
-                    .await?;
+            let (staged_table, new_hive_table) = self
+                .apply_and_prepare_update(commit, &db_name, &tbl_name, &hive_table)
+                .await?;
 
             self.client
                 .0

crates/catalog/hms/src/utils.rs

@@ -181,13 +181,15 @@ pub(crate) fn update_hive_table_from_table(
 
     let metadata_location = tbl.metadata_location_result()?.to_string();
 
-    let mut params: AHashMap<FastStr, FastStr> =
-        new_tbl.parameters.take().unwrap_or_default();
+    let mut params: AHashMap<FastStr, FastStr> = new_tbl.parameters.take().unwrap_or_default();
     for (k, v) in metadata.properties().iter() {
         if k == METADATA_LOCATION || k == TABLE_TYPE || k == EXTERNAL {
             continue;
         }
-        params.insert(FastStr::from_string(k.to_string()), FastStr::from_string(v.to_string()));
+        params.insert(
+            FastStr::from_string(k.to_string()),
+            FastStr::from_string(v.to_string()),
+        );
     }
 
     params.insert(FastStr::from(EXTERNAL), FastStr::from("TRUE"));
@@ -356,10 +358,7 @@ fn get_current_time() -> Result<i32> {
     })
 }
 
-pub(crate) fn create_lock_request(
-    db_name: &str,
-    tbl_name: &str,
-) -> hive_metastore::LockRequest {
+pub(crate) fn create_lock_request(db_name: &str, tbl_name: &str) -> hive_metastore::LockRequest {
     let component = hive_metastore::LockComponent {
         r#type: hive_metastore::LockType::EXCLUSIVE,
         level: hive_metastore::LockLevel::TABLE,

crates/catalog/hms/tests/hms_catalog_test.rs

@@ -24,6 +24,7 @@ use std::sync::RwLock;
 use ctor::{ctor, dtor};
 use iceberg::io::{S3_ACCESS_KEY_ID, S3_ENDPOINT, S3_REGION, S3_SECRET_ACCESS_KEY};
 use iceberg::spec::{NestedField, PrimitiveType, Schema, Type};
+use iceberg::transaction::{ApplyTransactionAction, Transaction};
 use iceberg::{Catalog, CatalogBuilder, Namespace, NamespaceIdent, TableCreation, TableIdent};
 use iceberg_catalog_hms::{
     HMS_CATALOG_PROP_THRIFT_TRANSPORT, HMS_CATALOG_PROP_URI, HMS_CATALOG_PROP_WAREHOUSE,
@@ -34,7 +35,6 @@ use iceberg_test_utils::{normalize_test_name, set_up};
 use port_scanner::scan_port_addr;
 use tokio::time::sleep;
 use tracing::info;
-use iceberg::transaction::{Transaction, ApplyTransactionAction};
 
 const HMS_CATALOG_PORT: u16 = 9083;
 const MINIO_PORT: u16 = 9000;
@@ -497,13 +497,19 @@ async fn test_update_table_with_optimistic_locking() -> Result<()> {
     let tx = Transaction::new(&table);
     let tx = tx
         .update_table_properties()
-        .set("test_property_optimistic".to_string(), "test_value_optimistic".to_string())
+        .set(
+            "test_property_optimistic".to_string(),
+            "test_value_optimistic".to_string(),
+        )
         .apply(tx)?;
 
     let updated_table = tx.commit(&catalog).await?;
 
     assert_eq!(
-        updated_table.metadata().properties().get("test_property_optimistic"),
+        updated_table
+            .metadata()
+            .properties()
+            .get("test_property_optimistic"),
         Some(&"test_value_optimistic".to_string())
     );
 
@@ -515,7 +521,10 @@ async fn test_update_table_with_optimistic_locking() -> Result<()> {
 
     let reloaded_table = catalog.load_table(table.identifier()).await?;
     assert_eq!(
-        reloaded_table.metadata().properties().get("test_property_optimistic"),
+        reloaded_table
+            .metadata()
+            .properties()
+            .get("test_property_optimistic"),
         Some(&"test_value_optimistic".to_string())
     );
     assert_eq!(