blaze: make parquet reader components public

Author: zhangli20

datafusion/datasource-parquet/src/mod.rs

@@ -22,8 +22,8 @@
 pub mod access_plan;
 pub mod file_format;
 mod metrics;
-mod opener;
-mod page_filter;
+pub mod opener;
+pub mod page_filter;
 mod reader;
 mod row_filter;
 mod row_group_filter;

datafusion/datasource-parquet/src/opener.rs

@@ -52,7 +52,7 @@ use parquet::arrow::{ParquetRecordBatchStreamBuilder, ProjectionMask};
 use parquet::file::metadata::ParquetMetaDataReader;
 
 /// Implements [`FileOpener`] for a parquet file
-pub(super) struct ParquetOpener {
+pub struct ParquetOpener {
     /// Execution partition index
     pub partition_index: usize,
     /// Column indexes in `table_schema` needed by the query
@@ -95,7 +95,7 @@ pub(super) struct ParquetOpener {
     /// Optional parquet FileDecryptionProperties
     pub file_decryption_properties: Option<Arc<FileDecryptionProperties>>,
     /// Rewrite expressions in the context of the file schema
-    pub(crate) expr_adapter_factory: Option<Arc<dyn PhysicalExprAdapterFactory>>,
+    pub expr_adapter_factory: Option<Arc<dyn PhysicalExprAdapterFactory>>,
 }
 
 impl FileOpener for ParquetOpener {

datafusion/datasource/src/schema_adapter.rs

@@ -355,16 +355,16 @@ where
 pub struct SchemaMapping {
     /// The schema of the table. This is the expected schema after conversion
     /// and it should match the schema of the query result.
-    projected_table_schema: SchemaRef,
+    pub projected_table_schema: SchemaRef,
     /// Mapping from field index in `projected_table_schema` to index in
     /// projected file_schema.
     ///
     /// They are Options instead of just plain `usize`s because the table could
     /// have fields that don't exist in the file.
-    field_mappings: Vec<Option<usize>>,
+    pub field_mappings: Vec<Option<usize>>,
     /// Function used to adapt a column from the file schema to the table schema
     /// when it exists in both schemas
-    cast_column: Arc<CastColumnFn>,
+    pub cast_column: Arc<CastColumnFn>,
 }
 
 impl Debug for SchemaMapping {