Test out pushdecoder

Author: Dandandan

datafusion/datasource-parquet/src/opener.rs

@@ -829,7 +829,7 @@ fn constant_value_from_stats(
 /// This can terminate the scan early when some dynamic filters is updated after
 /// the scan starts, so we discover after the scan starts that the file can be
 /// pruned (can't have matching rows).
-pub(crate) struct EarlyStoppingStream<S> {
+struct EarlyStoppingStream<S> {
     /// Has the stream finished processing? All subsequent polls will return
     /// None
     done: bool,
@@ -840,7 +840,7 @@ pub(crate) struct EarlyStoppingStream<S> {
 }
 
 impl<S> EarlyStoppingStream<S> {
-    pub(crate) fn new(
+    pub fn new(
         stream: S,
         file_pruner: FilePruner,
         files_ranges_pruned_statistics: PruningMetrics,
@@ -904,7 +904,7 @@ where
 }
 
 #[derive(Default)]
-pub(crate) struct EncryptionContext {
+struct EncryptionContext {
     #[cfg(feature = "parquet_encryption")]
     file_decryption_properties: Option<Arc<FileDecryptionProperties>>,
     #[cfg(feature = "parquet_encryption")]
@@ -913,7 +913,7 @@ pub(crate) struct EncryptionContext {
 
 #[cfg(feature = "parquet_encryption")]
 impl EncryptionContext {
-    pub(crate) fn new(
+    fn new(
         file_decryption_properties: Option<Arc<FileDecryptionProperties>>,
         encryption_factory: Option<(
             Arc<dyn EncryptionFactory>,
@@ -926,7 +926,7 @@ impl EncryptionContext {
         }
     }
 
-    pub(crate) async fn get_file_decryption_properties(
+    async fn get_file_decryption_properties(
         &self,
         file_location: &object_store::path::Path,
     ) -> Result<Option<Arc<FileDecryptionProperties>>> {
@@ -947,7 +947,7 @@ impl EncryptionContext {
 #[cfg(not(feature = "parquet_encryption"))]
 #[expect(dead_code)]
 impl EncryptionContext {
-    pub(crate) async fn get_file_decryption_properties(
+    async fn get_file_decryption_properties(
         &self,
         _file_location: &object_store::path::Path,
     ) -> Result<Option<Arc<FileDecryptionProperties>>> {
@@ -979,7 +979,7 @@ impl ParquetOpener {
 /// Returns an error if an invalid `ParquetAccessPlan` is provided
 ///
 /// Note: file_name is only used for error messages
-pub(crate) fn create_initial_plan(
+fn create_initial_plan(
     file_name: &str,
     extensions: Option<Arc<dyn std::any::Any + Send + Sync>>,
     row_group_count: usize,
@@ -1039,7 +1039,7 @@ pub(crate) fn build_pruning_predicates(
 
 /// Returns a `ArrowReaderMetadata` with the page index loaded, loading
 /// it from the underlying `AsyncFileReader` if necessary.
-pub(crate) async fn load_page_index<T: AsyncFileReader>(
+async fn load_page_index<T: AsyncFileReader>(
     reader_metadata: ArrowReaderMetadata,
     input: &mut T,
     options: ArrowReaderOptions,
@@ -1068,7 +1068,7 @@ pub(crate) async fn load_page_index<T: AsyncFileReader>(
     }
 }
 
-pub(crate) fn should_enable_page_index(
+fn should_enable_page_index(
     enable_page_index: bool,
     page_pruning_predicate: &Option<Arc<PagePruningAccessPlanFilter>>,
 ) -> bool {