File tree Expand file tree Collapse file tree
Expand file tree Collapse file tree Original file line number Diff line number Diff line change 2727
2828fn main ( ) {
2929 todo ! ( "Delta target is not yet implemented." )
30- }
30+ }
Original file line number Diff line number Diff line change 2727
2828fn main ( ) {
2929 todo ! ( "Iceberg target is not yet implemented." )
30- }
30+ }
Original file line number Diff line number Diff line change @@ -122,16 +122,16 @@ impl Cli {
122122 schema,
123123 out_file,
124124 } => ParquetConverter :: builder ( )
125- . with_in_file ( in_file. to_path_buf ( ) )
126- . with_schema ( schema. to_path_buf ( ) )
127- . with_out_file ( out_file. to_path_buf ( ) )
128- . with_num_threads ( n_threads)
129- . with_read_buffer_size ( read_buffer_size)
130- . with_thread_channel_capacity ( self . thread_channel_capacity )
131- . try_build ( ) ?
132- . try_convert ( ) ?,
125+ . with_in_file ( in_file. to_path_buf ( ) )
126+ . with_schema ( schema. to_path_buf ( ) )
127+ . with_out_file ( out_file. to_path_buf ( ) )
128+ . with_num_threads ( n_threads)
129+ . with_read_buffer_size ( read_buffer_size)
130+ . with_thread_channel_capacity ( self . thread_channel_capacity )
131+ . try_build ( ) ?
132+ . try_convert ( ) ?,
133133 } ;
134134
135135 Ok ( ( ) )
136136 }
137- }
137+ }
Original file line number Diff line number Diff line change @@ -47,4 +47,4 @@ fn main() {
4747 Ok ( _) => info ! ( "All done, bye! 🦖" ) ,
4848 Err ( e) => error ! ( "{}" , e) ,
4949 }
50- }
50+ }
You can’t perform that action at this time.
0 commit comments