implement replaceWhere

Signed-off-by: Nikolay Ulmasov <ulmasov@hotmail.com>
delta-io · Jan 28, 2024 · 292b0ce · 292b0ce
1 parent 1b6c830
commit 292b0ce
Show file tree

Hide file tree

Showing 10 changed files with 577 additions and 43 deletions.
diff --git a/crates/deltalake-core/src/delta_datafusion/mod.rs b/crates/deltalake-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();