File tree Expand file tree Collapse file tree 2 files changed +3
-1
lines changed Expand file tree Collapse file tree 2 files changed +3
-1
lines changed Original file line number Diff line number Diff line change @@ -30,7 +30,7 @@ pub enum DatasetError {
3030 #[ error( "Arrow error: {0}" ) ]
3131 Arrow ( #[ from] arrow:: error:: ArrowError ) ,
3232
33- #[ error( "{0}" ) ]
33+ #[ error( "Parquet error: {0}" ) ]
3434 Parquet ( #[ from] :: parquet:: errors:: ParquetError ) ,
3535
3636 #[ error( "Object store error: {0}" ) ]
Original file line number Diff line number Diff line change @@ -77,6 +77,7 @@ pub async fn read_metadata(
7777 path : impl Into < Path > ,
7878) -> Result < Arc < ParquetMetaData > > {
7979 let path = path. into ( ) ;
80+ println ! ( "Reading parquet metadata for {:?} on store {:?}" , path, store) ;
8081
8182 let mut object_reader = ParquetObjectReader :: new ( store, path. clone ( ) ) ;
8283 let metadata_reader = ParquetMetaDataReader :: new ( )
@@ -90,6 +91,7 @@ pub async fn read_metadata(
9091 // } else {
9192 // metadata.load_via_suffix_and_finish(self).await?
9293 // };
94+
9395 let metadata = metadata_reader
9496 . load_via_suffix_and_finish ( & mut object_reader)
9597 . await ?;
You can’t perform that action at this time.
0 commit comments