Function lance_datafusion::exec::reader_to_stream
source · pub fn reader_to_stream(
batches: Box<dyn RecordBatchReader + Send>
) -> Result<(SendableRecordBatchStream, Schema)>Expand description
Convert reader to a stream and a schema.
Will peek the first batch to get the dictionaries for dictionary columns.
NOTE: this does not validate the schema. For example, for appends the schema should be checked to make sure it matches the existing dataset schema before writing.