We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 16e392f commit 5272263Copy full SHA for 5272263
datafusion/src/avro_to_arrow/reader.rs
@@ -4,7 +4,7 @@ use crate::avro_to_arrow::arrow_array_reader::AvroArrowArrayReader;
4
use crate::error::Result;
5
use arrow::error::Result as ArrowResult;
6
use avro_rs::Reader as AvroReader;
7
-use std::io::{Read, Seek};
+use std::io::{Read, Seek, SeekFrom};
8
use std::sync::Arc;
9
10
/// Avro file reader builder
@@ -97,7 +97,7 @@ impl ReaderBuilder {
97
Some(schema) => schema,
98
None => Arc::new(infer_avro_schema_from_reader(&mut source)?),
99
};
100
- source.rewind()?;
+ source.seek(SeekFrom::Start(0))?;
101
Reader::try_new(source, schema, self.batch_size, self.projection)
102
}
103
0 commit comments