File tree Expand file tree Collapse file tree 1 file changed +8
-4
lines changed Expand file tree Collapse file tree 1 file changed +8
-4
lines changed Original file line number Diff line number Diff line change @@ -49,11 +49,13 @@ impl MergedRecordReader {
4949 log:: error!( "Invalid file detected, removing it: {:?}" , file) ;
5050 fs:: remove_file ( file) . unwrap ( ) ;
5151 } else {
52- let Ok ( reader) = StreamReader :: try_new ( BufReader :: new ( File :: open ( file) . unwrap ( ) ) , None ) else {
52+ let Ok ( reader) =
53+ StreamReader :: try_new ( BufReader :: new ( File :: open ( file) . unwrap ( ) ) , None )
54+ else {
5355 log:: error!( "Invalid file detected, ignoring it: {:?}" , file) ;
5456 continue ;
5557 } ;
56-
58+
5759 readers. push ( reader) ;
5860 }
5961 }
@@ -80,11 +82,13 @@ impl MergedReverseRecordReader {
8082 pub fn try_new ( files : & [ PathBuf ] ) -> Result < Self , ( ) > {
8183 let mut readers = Vec :: with_capacity ( files. len ( ) ) ;
8284 for file in files {
83- let Ok ( reader) = utils:: arrow:: reverse_reader:: get_reverse_reader ( File :: open ( file) . unwrap ( ) ) else {
85+ let Ok ( reader) =
86+ utils:: arrow:: reverse_reader:: get_reverse_reader ( File :: open ( file) . unwrap ( ) )
87+ else {
8488 log:: error!( "Invalid file detected, ignoring it: {:?}" , file) ;
8589 continue ;
8690 } ;
87-
91+
8892 readers. push ( reader) ;
8993 }
9094
You can’t perform that action at this time.
0 commit comments