diff --git a/src/io/parquet/read/record_batch.rs b/src/io/parquet/read/record_batch.rs index 8eb36e168e5..46bdd6138b5 100644 --- a/src/io/parquet/read/record_batch.rs +++ b/src/io/parquet/read/record_batch.rs @@ -90,6 +90,10 @@ impl RecordReader { &self.schema } + pub fn metadata(&self) -> &FileMetaData { + self.metadata.as_ref() + } + pub fn set_groups_filter(&mut self, groups_filter: GroupFilter) { self.groups_filter = Some(groups_filter); }