pub async fn file_to_stream(
store: &ObjectStore,
filename: &str,
file_schema: SchemaRef,
file_source: Arc<dyn FileSource>,
projection: Option<Vec<usize>>,
compression_type: CompressionType,
) -> Result<DfSendableRecordBatchStream>Expand description
Creates a [FileStream] for reading data from a file with optional column projection and compression support.
Returns [SendableRecordBatchStream].