cargo fmt

rust/src/operations/create.rs

@@ -251,7 +251,7 @@ impl CreateBuilder {
                 min_reader_version: MAX_SUPPORTED_READER_VERSION,
                 min_writer_version: MAX_SUPPORTED_WRITER_VERSION,
                 writer_features: None,
-                reader_features: None
+                reader_features: None,
             });
 
         let metadata = DeltaTableMetaData::new(
@@ -402,7 +402,7 @@ mod tests {
             min_reader_version: 0,
             min_writer_version: 0,
             writer_features: None,
-            reader_features: None
+            reader_features: None,
         };
         let table = CreateBuilder::new()
             .with_location("memory://")

rust/src/operations/restore.rs

@@ -205,8 +205,16 @@ async fn execute(
         Protocol {
             min_reader_version: table.get_min_reader_version(),
             min_writer_version: table.get_min_writer_version(),
-            writer_features: if snapshot.min_writer_version() < 7 { None } else { table.get_writer_features().cloned() },
-            reader_features: if snapshot.min_reader_version() < 3 { None } else { table.get_reader_features().cloned() }
+            writer_features: if snapshot.min_writer_version() < 7 {
+                None
+            } else {
+                table.get_writer_features().cloned()
+            },
+            reader_features: if snapshot.min_reader_version() < 3 {
+                None
+            } else {
+                table.get_reader_features().cloned()
+            },
         }
     } else {
         Protocol {
@@ -219,7 +227,7 @@ async fn execute(
                 snapshot.min_writer_version(),
             ),
             writer_features: snapshot.writer_features().cloned(),
-            reader_features: snapshot.reader_features().cloned()
+            reader_features: snapshot.reader_features().cloned(),
         }
     };
     actions.push(Action::protocol(protocol));

rust/src/operations/transaction/test_utils.rs

@@ -34,7 +34,7 @@ pub fn create_protocol_action(max_reader: Option<i32>, max_writer: Option<i32>)
         min_reader_version: max_reader.unwrap_or(crate::operations::MAX_SUPPORTED_READER_VERSION),
         min_writer_version: max_writer.unwrap_or(crate::operations::MAX_SUPPORTED_WRITER_VERSION),
         writer_features: None,
-        reader_features: None
+        reader_features: None,
     };
     Action::protocol(protocol)
 }
@@ -137,7 +137,7 @@ pub async fn create_initialized_table(
             min_reader_version: 1,
             min_writer_version: 1,
             writer_features: None,
-            reader_features: None
+            reader_features: None,
         },
         metadata: DeltaTableMetaData::new(
             None,

rust/src/protocol/checkpoints.rs

@@ -322,7 +322,7 @@ fn parquet_bytes_from_state(
         min_reader_version: state.min_reader_version(),
         min_writer_version: state.min_writer_version(),
         writer_features: None,
-        reader_features: None
+        reader_features: None,
     }))
     // metaData
     .chain(std::iter::once(Action::metaData(MetaData::try_from(

rust/src/protocol/mod.rs

@@ -648,7 +648,7 @@ pub struct Protocol {
     /// Table features are missing from older versions
     /// The table features this writer supports
     #[serde(skip_serializing_if = "Option::is_none")]
-    pub writer_features: Option<Vec<TableFeatures>>
+    pub writer_features: Option<Vec<TableFeatures>>,
 }
 
 /// Features table reader/writers can support as well as let users know
@@ -696,7 +696,7 @@ pub enum TableFeatures {
     ICEBERG_COMPAT_V1,
     /// liquid clustering support
     #[serde(alias = "liquid")]
-    LIQUID
+    LIQUID,
 }
 
 impl fmt::Display for TableFeatures {
@@ -715,12 +715,11 @@ impl fmt::Display for TableFeatures {
             TableFeatures::DOMAIN_METADATA => write!(f, "domainMetadata"),
             TableFeatures::V2_CHECKPOINT => write!(f, "v2Checkpoint"),
             TableFeatures::ICEBERG_COMPAT_V1 => write!(f, "icebergCompatV1"),
-            TableFeatures::LIQUID => write!(f, "liquid")
+            TableFeatures::LIQUID => write!(f, "liquid"),
         }
     }
 }
 
-
 /// The commitInfo is a fairly flexible action within the delta specification, where arbitrary data can be stored.
 /// However the reference implementation as well as delta-rs store useful information that may for instance
 /// allow us to be more permissive in commit conflict resolution.

rust/src/protocol/parquet2_read/mod.rs

@@ -614,24 +614,20 @@ fn deserialize_protocol_column_page(
                 |action: &mut Protocol, v: i32| action.min_writer_version = v,
             )?;
         }
-        "readerFeatures" => {
-            for_each_repeated_string_field_value(
-                actions,
-                page,
-                dict,
-                descriptor,
-                |action: &mut Protocol, v: Vec<String>| action.reader_features = Some(v)
-            )
-        }
-        "writerFeatures" => {
-            for_each_repeated_string_field_value(
-                actions,
-                page,
-                dict,
-                descriptor,
-                |action: &mut Protocol, v: Vec<String>| action.writer_features = Some(v)
-            )
-        }
+        "readerFeatures" => for_each_repeated_string_field_value(
+            actions,
+            page,
+            dict,
+            descriptor,
+            |action: &mut Protocol, v: Vec<String>| action.reader_features = Some(v),
+        ),
+        "writerFeatures" => for_each_repeated_string_field_value(
+            actions,
+            page,
+            dict,
+            descriptor,
+            |action: &mut Protocol, v: Vec<String>| action.writer_features = Some(v),
+        ),
         _ => {
             warn!("Unexpected field `{}` in protocol", f);
         }

rust/src/protocol/parquet_read/mod.rs

@@ -6,7 +6,10 @@ use num_traits::cast::ToPrimitive;
 use parquet::record::{Field, ListAccessor, MapAccessor, RowAccessor};
 use serde_json::json;
 
-use crate::protocol::{Action, Add, AddCDCFile, ColumnCountStat, ColumnValueStat, DeletionVector, MetaData, Protocol, ProtocolError, Remove, Stats, TableFeatures, Txn};
+use crate::protocol::{
+    Action, Add, AddCDCFile, ColumnCountStat, ColumnValueStat, DeletionVector, MetaData, Protocol,
+    ProtocolError, Remove, Stats, TableFeatures, Txn,
+};
 
 use super::StorageType;
 
@@ -592,25 +595,24 @@ impl Txn {
 impl From<&Field> for TableFeatures {
     fn from(value: &Field) -> Self {
         match value {
-            Field::Str(feature) =>
-                match feature.as_str() {
-                    "appendOnly" => TableFeatures::APPEND_ONLY,
-                    "invariants" => TableFeatures::INVARIANTS,
-                    "checkConstraints" => TableFeatures::CHECK_CONSTRAINTS,
-                    "changeDataFeed" => TableFeatures::CHANGE_DATA_FEED,
-                    "generatedColumns" => TableFeatures::GENERATED_COLUMNS,
-                    "columnMapping" => TableFeatures::COLUMN_MAPPING,
-                    "identityColumns" => TableFeatures::IDENTITY_COLUMNS,
-                    "deletionVectors" => TableFeatures::DELETION_VECTORS,
-                    "rowTracking" => TableFeatures::ROW_TRACKING,
-                    "timestampNtz" => TableFeatures::TIMESTAMP_WITHOUT_TIMEZONE,
-                    "domainMetadata" => TableFeatures::DOMAIN_METADATA,
-                    "v2Checkpoint" => TableFeatures::V2_CHECKPOINT,
-                    "icebergCompatV1" => TableFeatures::ICEBERG_COMPAT_V1,
-                    "liquid" => TableFeatures::LIQUID,
-                    f => panic!("Unknown table feature encountered: {}", f)
-                }
-            f => panic!("Invalid field type for table features: {}", f)
+            Field::Str(feature) => match feature.as_str() {
+                "appendOnly" => TableFeatures::APPEND_ONLY,
+                "invariants" => TableFeatures::INVARIANTS,
+                "checkConstraints" => TableFeatures::CHECK_CONSTRAINTS,
+                "changeDataFeed" => TableFeatures::CHANGE_DATA_FEED,
+                "generatedColumns" => TableFeatures::GENERATED_COLUMNS,
+                "columnMapping" => TableFeatures::COLUMN_MAPPING,
+                "identityColumns" => TableFeatures::IDENTITY_COLUMNS,
+                "deletionVectors" => TableFeatures::DELETION_VECTORS,
+                "rowTracking" => TableFeatures::ROW_TRACKING,
+                "timestampNtz" => TableFeatures::TIMESTAMP_WITHOUT_TIMEZONE,
+                "domainMetadata" => TableFeatures::DOMAIN_METADATA,
+                "v2Checkpoint" => TableFeatures::V2_CHECKPOINT,
+                "icebergCompatV1" => TableFeatures::ICEBERG_COMPAT_V1,
+                "liquid" => TableFeatures::LIQUID,
+                f => panic!("Unknown table feature encountered: {}", f),
+            },
+            f => panic!("Invalid field type for table features: {}", f),
         }
     }
 }
@@ -634,12 +636,14 @@ impl Protocol {
                     })?;
                 }
                 "readerFeatures" => {
-                    re.reader_features = record.get_list(i)
+                    re.reader_features = record
+                        .get_list(i)
                         .and_then(|l| Ok(l.elements().iter().map(From::from).collect()))
                         .ok();
                 }
                 "writerFeatures" => {
-                    re.writer_features = record.get_list(i)
+                    re.writer_features = record
+                        .get_list(i)
                         .and_then(|l| Ok(l.elements().iter().map(From::from).collect()))
                         .ok();
                 }

rust/src/table/mod.rs

@@ -23,7 +23,9 @@ use self::builder::DeltaTableConfig;
 use self::state::DeltaTableState;
 use crate::errors::DeltaTableError;
 use crate::partitions::PartitionFilter;
-use crate::protocol::{self, find_latest_check_point_for_version, get_last_checkpoint, Action, TableFeatures};
+use crate::protocol::{
+    self, find_latest_check_point_for_version, get_last_checkpoint, Action, TableFeatures,
+};
 use crate::protocol::{Add, ProtocolError, Stats};
 use crate::schema::*;
 use crate::storage::{commit_uri_from_version, ObjectStoreRef};