Struct AvroObjectReader 

pub struct AvroObjectReader { /* private fields */ }

👎Deprecated since 59.2.0:

Implement AsyncFileReader directly instead; see the example on the AsyncFileReader trait documentation and arrow-avro/examples/object_store.rs. Use SpawnedReader to perform I/O on a dedicated runtime. See also https://github.com/apache/arrow-rs/issues/10308

Available on crate features async and object_store only.

An implementation of an AsyncFileReader using the ObjectStore API.

Implementations

impl AvroObjectReader

pub fn new(store: Arc<dyn ObjectStore>, path: Path) -> Self

Creates a new Self from a store implementation and file location.

pub fn with_runtime(self, handle: Handle) -> Self

👎Deprecated since 59.2.0:

Wrap the reader in a SpawnedReader instead, e.g. SpawnedReader::new(reader, handle). See also https://github.com/apache/arrow-rs/issues/10308

Perform IO on the provided tokio runtime

Tokio is a cooperative scheduler, and relies on tasks yielding in a timely manner to service IO. Therefore, running IO and CPU-bound tasks, such as avro decoding, on the same tokio runtime can lead to degraded throughput, dropped connections and other issues. For more information see here.

Trait Implementations

impl AsyncFileReader for AvroObjectReader

fn get_bytes( &mut self, range: Range<u64>, ) -> BoxFuture<'_, Result<Bytes, AvroError>>

Retrieve the bytes in range

fn get_byte_ranges( &mut self, ranges: Vec<Range<u64>>, ) -> BoxFuture<'_, Result<Vec<Bytes>, AvroError>>

where Self: Send,

Retrieve multiple byte ranges. The default implementation will call get_bytes sequentially

impl Clone for AvroObjectReader

fn clone(&self) -> AvroObjectReader

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for AvroObjectReader

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.