implement replaceWhere

Signed-off-by: Nikolay Ulmasov <ulmasov@hotmail.com>
delta-io · Jan 30, 2024 · 96ac7ea · 96ac7ea
1 parent 8f938ed
commit 96ac7ea
Show file tree

Hide file tree

Showing 10 changed files with 577 additions and 43 deletions.
diff --git a/crates/core/src/delta_datafusion/mod.rs b/crates/core/src/delta_datafusion/mod.rs
@@ -878,6 +878,12 @@ impl DeltaDataChecker {
         self
     }
 
+    /// Add the specified set of constraints to the current DeltaDataChecker's constraints
+    pub fn with_extra_constraints(mut self, constraints: Vec<Constraint>) -> Self {
+        self.constraints.extend(constraints);
+        self
+    }
+
     /// Create a new DeltaDataChecker
     pub fn new(snapshot: &DeltaTableState) -> Self {
         let invariants = snapshot.schema().get_invariants().unwrap_or_default();