Skip to content

Commit 9d71eb5

Browse files
zhangli20zhangli20
authored andcommitted
blaze: make parquet reader components public
1 parent e6ee46f commit 9d71eb5

File tree

3 files changed

+5
-5
lines changed

3 files changed

+5
-5
lines changed

datafusion/datasource-parquet/src/mod.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -23,7 +23,7 @@ pub mod access_plan;
2323
pub mod file_format;
2424
mod metrics;
2525
mod opener;
26-
mod page_filter;
26+
pub mod page_filter;
2727
mod reader;
2828
mod row_filter;
2929
mod row_group_filter;

datafusion/datasource-parquet/src/opener.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -52,7 +52,7 @@ use parquet::arrow::{ParquetRecordBatchStreamBuilder, ProjectionMask};
5252
use parquet::file::metadata::ParquetMetaDataReader;
5353

5454
/// Implements [`FileOpener`] for a parquet file
55-
pub(super) struct ParquetOpener {
55+
pub struct ParquetOpener {
5656
/// Execution partition index
5757
pub partition_index: usize,
5858
/// Column indexes in `table_schema` needed by the query

datafusion/datasource/src/schema_adapter.rs

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -355,16 +355,16 @@ where
355355
pub struct SchemaMapping {
356356
/// The schema of the table. This is the expected schema after conversion
357357
/// and it should match the schema of the query result.
358-
projected_table_schema: SchemaRef,
358+
pub projected_table_schema: SchemaRef,
359359
/// Mapping from field index in `projected_table_schema` to index in
360360
/// projected file_schema.
361361
///
362362
/// They are Options instead of just plain `usize`s because the table could
363363
/// have fields that don't exist in the file.
364-
field_mappings: Vec<Option<usize>>,
364+
pub field_mappings: Vec<Option<usize>>,
365365
/// Function used to adapt a column from the file schema to the table schema
366366
/// when it exists in both schemas
367-
cast_column: Arc<CastColumnFn>,
367+
pub cast_column: Arc<CastColumnFn>,
368368
}
369369

370370
impl Debug for SchemaMapping {

0 commit comments

Comments
 (0)