Method open

datafusion/datasource-avro/src/source.rs:57–68

(
        &self,
        reader: R,
        projection: Option<Vec<usize>>,
    )

    }

    fn open<R: std::io::BufRead>(
        &self,
        reader: R,
        projection: Option<Vec<usize>>,
    ) -> Result<Reader<R>> {
        let mut builder = ReaderBuilder::new()
            .with_batch_size(self.batch_size.expect("Batch size must set before open"));
        if let Some(projection) = projection {
            builder = builder.with_projection(projection);
        }
        builder.build(reader).map_err(Into::into)
    }

    fn projected_file_schema(&self) -> SchemaRef {
        let file_schema = self.table_schema.file_schema();