fix(log-store): ensure UpdateDelete and UpdateInsert in the same chunk (

#17364)
risingwavelabs · Jun 20, 2024 · 5c0ecf3 · 5c0ecf3
1 parent 7df77a4
commit 5c0ecf3
Show file tree

Hide file tree

Showing 2 changed files with 290 additions and 85 deletions.
diff --git a/src/common/src/util/chunk_coalesce.rs b/src/common/src/util/chunk_coalesce.rs
@@ -228,6 +228,10 @@ impl DataChunkBuilder {
         self.buffered_count
     }
 
+    pub fn can_append(&self, count: usize) -> bool {
+        self.buffered_count + count <= self.batch_size
+    }
+
     pub fn num_columns(&self) -> usize {
         self.data_types.len()
     }