diff --git a/rust/lancedb/src/table/datafusion.rs b/rust/lancedb/src/table/datafusion.rs index 940b8831..949c47fe 100644 --- a/rust/lancedb/src/table/datafusion.rs +++ b/rust/lancedb/src/table/datafusion.rs @@ -85,6 +85,14 @@ impl ExecutionPlan for MetadataEraserExec { vec![&self.input] } + fn maintains_input_order(&self) -> Vec { + vec![true; self.children().len()] + } + + fn benefits_from_input_partitioning(&self) -> Vec { + vec![false; self.children().len()] + } + fn with_new_children( self: Arc, children: Vec>, @@ -486,7 +494,6 @@ pub mod tests { TestFixture::check_plan( plan, "MetadataEraserExec - RepartitionExec:... ProjectionExec:... LanceRead:...", )