File tree Expand file tree Collapse file tree 1 file changed +8
-0
lines changed
parquet/src/arrow/async_writer Expand file tree Collapse file tree 1 file changed +8
-0
lines changed Original file line number Diff line number Diff line change @@ -292,7 +292,13 @@ impl<W: AsyncFileWriter> AsyncArrowWriter<W> {
292292 /// Create a new row group writer and return its column writers.
293293 pub async fn get_column_writers ( & mut self ) -> Result < Vec < ArrowColumnWriter > > {
294294 let before = self . sync_writer . flushed_row_groups ( ) . len ( ) ;
295+ // TODO: should use the new API
296+ #[ allow( deprecated) ]
295297 let writers = self . sync_writer . get_column_writers ( ) ?;
298+ // let (serialized_file_writer, arrow_row_group_writer_factory) =
299+ // self.sync_writer.into_serialized_writer().unwrap();
300+ // let writers = row_group_writer_factory.create_column_writers(0).unwrap();
301+ // let metadata = serialized_file_writer.close().unwrap();
296302 if before != self . sync_writer . flushed_row_groups ( ) . len ( ) {
297303 self . do_write ( ) . await ?;
298304 }
@@ -301,6 +307,8 @@ impl<W: AsyncFileWriter> AsyncArrowWriter<W> {
301307
302308 /// Append the given column chunks to the file as a new row group.
303309 pub async fn append_row_group ( & mut self , chunks : Vec < ArrowColumnChunk > ) -> Result < ( ) > {
310+ // TODO: should use the new API
311+ #[ allow( deprecated) ]
304312 self . sync_writer . append_row_group ( chunks) ?;
305313 self . do_write ( ) . await
306314 }
You can’t perform that action at this time.
0 commit comments