File tree Expand file tree Collapse file tree
datafusion/datasource-avro/src Expand file tree Collapse file tree Original file line number Diff line number Diff line change 1616// under the License.
1717
1818//! Apache Avro [`FileFormat`] abstractions
19-
19+ // todo - Check if it can be replaced with arrow-avro
2020use std:: any:: Any ;
2121use std:: collections:: HashMap ;
2222use std:: fmt;
Original file line number Diff line number Diff line change @@ -56,9 +56,9 @@ impl AvroSource {
5656 self . schema . expect ( "Schema must set before open" ) . as_ref ( ) ,
5757 ) ?;
5858 ReaderBuilder :: new ( )
59- . with_reader_schema ( avro_schema)
59+ . with_reader_schema ( avro_schema) // Used for projection on read.
6060 . with_batch_size ( self . batch_size . expect ( "Batch size must set before open" ) )
61- . build ( reader)
61+ . build ( reader) // TODO - A File (which doesn't implement BufRead) is being passed; confirm whether this is safe.
6262 . map_err ( Into :: into)
6363 }
6464}
You can’t perform that action at this time.
0 commit comments