@@ -71,55 +71,55 @@ pub(super) struct ParquetOpener {
7171 /// Execution partition index
7272 pub ( crate ) partition_index : usize ,
7373 /// Projection to apply on top of the table schema (i.e. can reference partition columns).
74- pub projection : ProjectionExprs ,
74+ pub ( crate ) projection : ProjectionExprs ,
7575 /// Target number of rows in each output RecordBatch
76- pub batch_size : usize ,
76+ pub ( crate ) batch_size : usize ,
7777 /// Optional limit on the number of rows to read
7878 pub ( crate ) limit : Option < usize > ,
7979 /// If should keep the output rows in order
80- pub preserve_order : bool ,
80+ pub ( crate ) preserve_order : bool ,
8181 /// Optional predicate to apply during the scan
82- pub predicate : Option < Arc < dyn PhysicalExpr > > ,
82+ pub ( crate ) predicate : Option < Arc < dyn PhysicalExpr > > ,
8383 /// Table schema, including partition columns.
84- pub table_schema : TableSchema ,
84+ pub ( crate ) table_schema : TableSchema ,
8585 /// Optional hint for how large the initial request to read parquet metadata
8686 /// should be
87- pub metadata_size_hint : Option < usize > ,
87+ pub ( crate ) metadata_size_hint : Option < usize > ,
8888 /// Metrics for reporting
89- pub metrics : ExecutionPlanMetricsSet ,
89+ pub ( crate ) metrics : ExecutionPlanMetricsSet ,
9090 /// Factory for instantiating parquet reader
91- pub parquet_file_reader_factory : Arc < dyn ParquetFileReaderFactory > ,
91+ pub ( crate ) parquet_file_reader_factory : Arc < dyn ParquetFileReaderFactory > ,
9292 /// Should the filters be evaluated during the parquet scan using
9393 /// [`DataFusionArrowPredicate`](row_filter::DatafusionArrowPredicate)?
94- pub pushdown_filters : bool ,
94+ pub ( crate ) pushdown_filters : bool ,
9595 /// Should the filters be reordered to optimize the scan?
96- pub reorder_filters : bool ,
96+ pub ( crate ) reorder_filters : bool ,
9797 /// Should we force the reader to use RowSelections for filtering
98- pub force_filter_selections : bool ,
98+ pub ( crate ) force_filter_selections : bool ,
9999 /// Should the page index be read from parquet files, if present, to skip
100100 /// data pages
101- pub enable_page_index : bool ,
101+ pub ( crate ) enable_page_index : bool ,
102102 /// Should the bloom filter be read from parquet, if present, to skip row
103103 /// groups
104- pub enable_bloom_filter : bool ,
104+ pub ( crate ) enable_bloom_filter : bool ,
105105 /// Should row group pruning be applied
106- pub enable_row_group_stats_pruning : bool ,
106+ pub ( crate ) enable_row_group_stats_pruning : bool ,
107107 /// Coerce INT96 timestamps to specific TimeUnit
108- pub coerce_int96 : Option < TimeUnit > ,
108+ pub ( crate ) coerce_int96 : Option < TimeUnit > ,
109109 /// Optional parquet FileDecryptionProperties
110110 #[ cfg( feature = "parquet_encryption" ) ]
111- pub file_decryption_properties : Option < Arc < FileDecryptionProperties > > ,
111+ pub ( crate ) file_decryption_properties : Option < Arc < FileDecryptionProperties > > ,
112112 /// Rewrite expressions in the context of the file schema
113113 pub ( crate ) expr_adapter_factory : Arc < dyn PhysicalExprAdapterFactory > ,
114114 /// Optional factory to create file decryption properties dynamically
115115 #[ cfg( feature = "parquet_encryption" ) ]
116- pub encryption_factory :
116+ pub ( crate ) encryption_factory :
117117 Option < ( Arc < dyn EncryptionFactory > , EncryptionFactoryOptions ) > ,
118118 /// Maximum size of the predicate cache, in bytes. If none, uses
119119 /// the arrow-rs default.
120- pub max_predicate_cache_size : Option < usize > ,
120+ pub ( crate ) max_predicate_cache_size : Option < usize > ,
121121 /// Whether to read row groups in reverse order
122- pub reverse_row_groups : bool ,
122+ pub ( crate ) reverse_row_groups : bool ,
123123}
124124
125125/// Represents a prepared access plan with optional row selection
0 commit comments