Struct CloudObjectReader 

pub struct CloudObjectReader {
    pub object_store: Arc<dyn ObjectStore>,
    pub path: Path,
    /* private fields */
}

Object Reader

Object Store + Base Path

Fields

object_store: Arc<dyn ObjectStore>

path: Path

Implementations

impl CloudObjectReader

pub fn new( object_store: Arc<dyn ObjectStore>, path: Path, block_size: usize, known_size: Option<usize>, download_retry_count: usize, ) -> Result<Self>

Create an ObjectReader from URI

pub fn with_io_parallelism(self, io_parallelism: usize) -> Self

Override the I/O parallelism this reader advertises.

ObjectStore::open / open_with_size pass their normalized effective parallelism (LANCE_IO_THREADS override applied, at least 1) so consumers that size concurrency windows off the reader honor the configured request limit instead of the hardcoded cloud default.

Trait Implementations

impl Debug for CloudObjectReader

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

Formats the value using the given formatter.

impl DeepSizeOf for CloudObjectReader

fn deep_size_of_children(&self, context: &mut Context) -> usize

fn deep_size_of(&self) -> usize

impl Reader for CloudObjectReader

fn size(&self) -> BoxFuture<'_, Result<usize>>

Object/File Size.

fn path(&self) -> &Path

fn block_size(&self) -> usize

Suggest optimal I/O size per storage device.

fn io_parallelism(&self) -> usize

Suggest optimal I/O parallelism per storage device.

fn get_range(&self, range: Range<usize>) -> BoxFuture<'static, OSResult<Bytes>>

Read a range of bytes from the object.

fn get_all(&self) -> BoxFuture<'_, OSResult<Bytes>>

Read all bytes from the object.

fn get_stream(&self) -> BoxFuture<'_, OSResult<ByteStream>>

Read the entire object as a byte stream.

fn get_range_stream( &self, range: Range<usize>, ) -> BoxFuture<'_, OSResult<ByteStream>>

Read a byte range as a byte stream.