Struct LanceDataset 

pub struct LanceDataset { /* private fields */ }

Implementations

impl LanceDataset

pub async fn open(path: &Path, lance: Option<&LanceArgs>) -> Result<Self>

Trait Implementations

impl Dataset for LanceDataset

fn origin(&self) -> &Path

Path or URI the dataset was opened from.

fn arrow_schema(&self) -> SchemaRef

Logical arrow schema of the dataset.

fn physical_schema_debug(&self, projection: Option<&[String]>) -> Result<String>

Pretty-printed format-native schema (for schema --type physical), optionally projected to a subset of columns.

fn count_rows<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<u64>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Total row count.

fn scan<'life0, 'life1, 'async_trait>( &'life0 self, projection: Option<&'life1 [String]>, ) -> Pin<Box<dyn Future<Output = Result<BatchStream>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Stream all rows, optionally projected to the given columns.

fn take<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, indices: &'life1 [u64], projection: Option<&'life2 [String]>, ) -> Pin<Box<dyn Future<Output = Result<RecordBatch>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Materialise a RecordBatch containing only the rows at the given indices, in the order given. indices must all be < count_rows().

fn lance(&self) -> Option<&dyn LanceCapabilities>

Returns Some(...) when this dataset is backed by a format that supports Lance-specific operations (versions, branches, indices). The default None covers any future format that doesn’t.

impl Debug for LanceDataset

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

Formats the value using the given formatter.

impl LanceCapabilities for LanceDataset

fn list_versions<'life0, 'life1, 'async_trait>( &'life0 self, branch: Option<&'life1 str>, tagged_only: bool, ) -> Pin<Box<dyn Future<Output = Result<Vec<VersionInfo>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

List versions on branch (defaults to main when None). When tagged_only is true, drops untagged versions from the result.

fn list_branches<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Vec<BranchInfo>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

List every branch the dataset has, including the default main.

fn list_tags<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Vec<TagInfo>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

List every tag in the dataset, regardless of branch.

fn list_indices<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Vec<IndexInfo>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

List indices defined on the active version of the dataset.