MCPcopy Create free account
hub / github.com/apache/arrow-rs / get_bytes

Method get_bytes

arrow-avro/src/reader/async_reader/store.rs:94–96  ·  view source on GitHub ↗
(&mut self, range: Range<u64>)

Source from the content-addressed store, hash-verified

92
93impl AsyncFileReader for AvroObjectReader {
94 fn get_bytes(&mut self, range: Range<u64>) -> BoxFuture<'_, Result<Bytes, AvroError>> {
95 self.spawn(|store, path| async move { store.get_range(path, range).await }.boxed())
96 }
97
98 fn get_byte_ranges(
99 &mut self,

Callers 2

fetch_bytesMethod · 0.45
read_headerFunction · 0.45

Calls 1

spawnMethod · 0.45

Tested by

no test coverage detected