feat: add enforcement for invariants to commit checker

crates/deltalake-core/src/kernel/actions/types.rs

@@ -264,7 +264,7 @@ pub enum WriterFeatures {
     /// ID Columns
     IdentityColumns,
     /// Deletion vectors for merge, update, delete
-    DeleteionVecotrs,
+    DeletionVectors,
     /// Row tracking on tables
     RowTracking,
     /// timestamps without timezone support
@@ -291,7 +291,7 @@ impl Into<usize> for WriterFeatures {
             WriterFeatures::ChangeDataFeed | WriterFeatures::GeneratedColumns => 4,
             WriterFeatures::ColumnMapping => 5,
             WriterFeatures::IdentityColumns
-            | WriterFeatures::DeleteionVecotrs
+            | WriterFeatures::DeletionVectors
             | WriterFeatures::RowTracking
             | WriterFeatures::TimestampWithoutTimezone
             | WriterFeatures::DomainMetadata
@@ -311,7 +311,7 @@ impl From<String> for WriterFeatures {
             "generatedColumns" => WriterFeatures::GeneratedColumns,
             "columnMapping" => WriterFeatures::ColumnMapping,
             "identityColumns" => WriterFeatures::IdentityColumns,
-            "deletionVectors" => WriterFeatures::DeleteionVecotrs,
+            "deletionVectors" => WriterFeatures::DeletionVectors,
             "rowTracking" => WriterFeatures::RowTracking,
             "timestampNtz" => WriterFeatures::TimestampWithoutTimezone,
             "domainMetadata" => WriterFeatures::DomainMetadata,
@@ -332,7 +332,7 @@ impl AsRef<str> for WriterFeatures {
             WriterFeatures::GeneratedColumns => "generatedColumns",
             WriterFeatures::ColumnMapping => "columnMapping",
             WriterFeatures::IdentityColumns => "identityColumns",
-            WriterFeatures::DeleteionVecotrs => "deletionVectors",
+            WriterFeatures::DeletionVectors => "deletionVectors",
             WriterFeatures::RowTracking => "rowTracking",
             WriterFeatures::TimestampWithoutTimezone => "timestampNtz",
             WriterFeatures::DomainMetadata => "domainMetadata",
@@ -361,7 +361,7 @@ impl From<&parquet::record::Field> for WriterFeatures {
                 "generatedColumns" => WriterFeatures::GeneratedColumns,
                 "columnMapping" => WriterFeatures::ColumnMapping,
                 "identityColumns" => WriterFeatures::IdentityColumns,
-                "deletionVectors" => WriterFeatures::DeleteionVecotrs,
+                "deletionVectors" => WriterFeatures::DeletionVectors,
                 "rowTracking" => WriterFeatures::RowTracking,
                 "timestampNtz" => WriterFeatures::TimestampWithoutTimezone,
                 "domainMetadata" => WriterFeatures::DomainMetadata,

crates/deltalake-core/src/operations/transaction/protocol.rs

@@ -142,6 +142,25 @@ impl ProtocolChecker {
             })?;
         }
 
+        // Does the table have invariants?
+        let invariants = snapshot
+            .current_metadata()
+            .and_then(|meta| meta.schema.get_invariants().ok())
+            .unwrap_or_default()
+            .is_empty();
+
+        // The table is at least version 7, has actual invariants and has the proper writer feature
+        // enabled
+        if snapshot.min_writer_version() >= 7
+            && !invariants
+            && !snapshot
+            .writer_features()
+            .unwrap()
+            .contains(&WriterFeatures::Invariants)
+        {
+            return Err(TransactionError::WriterFeaturesRequired);
+        }
+
         Ok(())
     }
 }