diff --git a/src/rewrite/exploitation.rs b/src/rewrite/exploitation.rs index 7a95113..b353a84 100644 --- a/src/rewrite/exploitation.rs +++ b/src/rewrite/exploitation.rs @@ -450,6 +450,10 @@ impl ExecutionPlan for OneOfExec { )?)) } + fn supports_limit_pushdown(&self) -> bool { + true + } + fn execute( &self, partition: usize,