@@ -710,11 +710,9 @@ impl CubeTable {
710710 let mut options = TableParquetOptions :: new ( ) ;
711711 options. global = state. config_options ( ) . execution . parquet . clone ( ) ;
712712
713- let parquet_source = ParquetSource :: new (
714- options,
715- get_reader_options_customizer ( state. config ( ) ) ,
716- )
717- . with_parquet_file_reader_factory ( self . parquet_metadata_cache . clone ( ) ) ;
713+ let parquet_source =
714+ ParquetSource :: new ( options, get_reader_options_customizer ( state. config ( ) ) )
715+ . with_parquet_file_reader_factory ( self . parquet_metadata_cache . clone ( ) ) ;
718716 let parquet_source = if let Some ( phys_pred) = & physical_predicate {
719717 parquet_source. with_predicate ( index_schema. clone ( ) , phys_pred. clone ( ) )
720718 } else {
@@ -792,11 +790,9 @@ impl CubeTable {
792790
793791 let mut options = TableParquetOptions :: new ( ) ;
794792 options. global = state. config_options ( ) . execution . parquet . clone ( ) ;
795- let parquet_source = ParquetSource :: new (
796- options,
797- get_reader_options_customizer ( state. config ( ) ) ,
798- )
799- . with_parquet_file_reader_factory ( self . parquet_metadata_cache . clone ( ) ) ;
793+ let parquet_source =
794+ ParquetSource :: new ( options, get_reader_options_customizer ( state. config ( ) ) )
795+ . with_parquet_file_reader_factory ( self . parquet_metadata_cache . clone ( ) ) ;
800796 let parquet_source = if let Some ( phys_pred) = & physical_predicate {
801797 parquet_source. with_predicate ( index_schema. clone ( ) , phys_pred. clone ( ) )
802798 } else {
0 commit comments