Update to columnar 0.10 and make flush public

frankmcsherry · frankmcsherry · commit 33a8876acb4a · 2025-08-05T12:09:00.000-04:00
diff --git a/Cargo.toml b/Cargo.toml
@@ -14,7 +14,7 @@ resolver = "2"
 edition = "2021"
 
 [workspace.dependencies]
-columnar = "0.9"
+columnar = "0.10"
 
 [workspace.lints.clippy]
 type_complexity = "allow"
diff --git a/timely/src/dataflow/operators/core/input.rs b/timely/src/dataflow/operators/core/input.rs
@@ -366,7 +366,7 @@ impl<T: Timestamp, CB: ContainerBuilder> Handle<T, CB> {
 
     /// Flush all contents and distribute to downstream operators.
     #[inline]
-    fn flush(&mut self) {
+    pub fn flush(&mut self) {
         while let Some(container) = self.builder.finish() {
             Self::send_container(container, &mut self.buffer, &mut self.pushers, &self.now_at);
         }

Original file line number	Diff line number	Diff line change
`@@ -366,7 +366,7 @@ impl<T: Timestamp, CB: ContainerBuilder> Handle<T, CB> {`
`366`	`366`
`367`	`367`	`/// Flush all contents and distribute to downstream operators.`
`368`	`368`	`#[inline]`
`369`		`- fn flush(&mut self) {`
	`369`	`+ pub fn flush(&mut self) {`
`370`	`370`	`while let Some(container) = self.builder.finish() {`
`371`	`371`	`Self::send_container(container, &mut self.buffer, &mut self.pushers, &self.now_at);`
`372`	`372`	`}`