draft implementation for replaceWhere

Signed-off-by: Nikolay Ulmasov <[email protected]>
delta-io · Dec 28, 2023 · 592355e · 592355e
1 parent bc9253c
commit 592355e
Show file tree

Hide file tree

Showing 3 changed files with 309 additions and 36 deletions.
diff --git a/crates/deltalake-core/src/delta_datafusion/mod.rs b/crates/deltalake-core/src/delta_datafusion/mod.rs
@@ -1078,6 +1078,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 metadata = snapshot.metadata();