We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent f0d6048 commit 66d8dfeCopy full SHA for 66d8dfe
vortex-datafusion/src/persistent/source.rs
@@ -230,6 +230,12 @@ impl FileSource for VortexSource {
230
filters: Vec<Arc<dyn PhysicalExpr>>,
231
_config: &ConfigOptions,
232
) -> DFResult<FilterPushdownPropagation<Arc<dyn FileSource>>> {
233
+ if filters.is_empty() {
234
+ return Ok(FilterPushdownPropagation::with_parent_pushdown_result(
235
+ vec![],
236
+ ));
237
+ }
238
+
239
let Some(schema) = self.arrow_file_schema.as_ref() else {
240
return Ok(FilterPushdownPropagation::with_parent_pushdown_result(
241
vec![PushedDown::No; filters.len()],
0 commit comments