Function iceberg_rust::arrow::read::read

source ·
pub async fn read(
    manifest_files: impl Iterator<Item = ManifestEntry>,
    object_store: Arc<dyn ObjectStore>
) -> impl Stream<Item = Result<RecordBatch, ParquetError>>
Expand description

Read a parquet file into a stream of arrow recordbatches. The record batches are read asynchronously and are unordered