diff --git a/arrow-csv/src/reader/mod.rs b/arrow-csv/src/reader/mod.rs index 74294f42e8b2..0ab1664f5d00 100644 --- a/arrow-csv/src/reader/mod.rs +++ b/arrow-csv/src/reader/mod.rs @@ -490,6 +490,12 @@ impl Iterator for BufReader { } } +impl RecordBatchReader for BufReader { + fn schema(&self) -> SchemaRef { + self.decoder.schema.clone() + } +} + /// A push-based interface for decoding CSV data from an arbitrary byte stream /// /// See [`Reader`] for a higher-level interface for interface with [`Read`]