Struct AsyncOpendalReader

pub struct AsyncOpendalReader { /* private fields */ }

AsyncOpendalReader provides native support for opendal

use opendal::Operator;
use std::io::Result;
use orc_rust::reader::AsyncOpendalReader;
use orc_rust::reader::AsyncChunkReader;
use opendal::services::MemoryConfig;

let op = Operator::from_config(MemoryConfig::default())?.finish();
op.write("test", "Hello, world!").await?;

let mut reader = AsyncOpendalReader::new(op, "test");
let len = reader.len().await?;
let data = reader.get_bytes(0, len).await?;

Implementations

impl AsyncOpendalReader

pub fn new(op: Operator, path: &str) -> Self

Create a new async opendal reader.

Trait Implementations

impl AsyncChunkReader for AsyncOpendalReader

fn len(&mut self) -> BoxFuture<'_, Result<u64>>

fn get_bytes( &mut self, offset_from_start: u64, length: u64, ) -> BoxFuture<'_, Result<Bytes>>