Module async_reader 

Available on crate feature async only.

Asynchronous implementation of Avro file reader.

This module provides AsyncAvroFileReader, which supports reading and decoding the Avro OCF format from any source that implements AsyncFileReader.

Structs

AsyncAvroFileReader

An asynchronous Avro file reader that implements Stream<Item = Result<RecordBatch, ArrowError>>. This uses an AsyncFileReader to fetch data ranges as needed, starting with fetching the header, then reading all the blocks in the provided range where:

AvroObjectReaderobject_store

An implementation of an AsyncFileReader using the ObjectStore API.

ReaderBuilder

Builder for an asynchronous Avro file reader.

Traits

AsyncFileReader

The asynchronous interface used by super::AsyncAvroFileReader to read avro files

Functions

read_header_info

Reads the Avro file header (magic, metadata, sync marker) asynchronously from reader.