diff --git a/datafusion/core/src/datasource/physical_plan/parquet/mod.rs b/datafusion/core/src/datasource/physical_plan/parquet/mod.rs index cb038a2e4889a..07c40f2e98ebc 100644 --- a/datafusion/core/src/datasource/physical_plan/parquet/mod.rs +++ b/datafusion/core/src/datasource/physical_plan/parquet/mod.rs @@ -199,6 +199,10 @@ pub struct ParquetExec { table_parquet_options: TableParquetOptions, /// Optional user defined schema adapter schema_adapter_factory: Option>, + /// Optional starting RowGroupSets for each file in the file groups + /// TODO encapsulate into some sort of struct that can also have + /// page filters / selections + row_groups: Vec>, } /// [`ParquetExecBuilder`]`, builder for [`ParquetExec`]. @@ -393,6 +397,7 @@ impl ParquetExecBuilder { cache, table_parquet_options, schema_adapter_factory, + row_groups, } } }