pub struct IceDiskRelTable {
pub name: String,
pub layout: IceDiskRelTableLayout,
pub indices_file_path: PathBuf,
pub indptr_file_path: Option<PathBuf>,
}Expand description
The ICE (IceDisk) native disk format for relationship tables.
Based on Ladybug’s IceDiskRelTable implementation, which stores
relational data directly in Parquet format files (indices.parquet and optionally indptr.parquet).
Fields§
§name: String§layout: IceDiskRelTableLayout§indices_file_path: PathBuf§indptr_file_path: Option<PathBuf>Implementations§
Source§impl IceDiskRelTable
impl IceDiskRelTable
Sourcepub fn new(
name: String,
base_path: &Path,
layout: IceDiskRelTableLayout,
) -> Self
pub fn new( name: String, base_path: &Path, layout: IceDiskRelTableLayout, ) -> Self
Initialize a new IceDiskRelTable pointing to its Parquet files.
Sourcepub fn scan_indices(
&self,
vfs: &VirtualFileSystemRegistry,
columns: &[CatalogColumn],
) -> Result<IceDiskRelTableScanState, ParquetReaderError>
pub fn scan_indices( &self, vfs: &VirtualFileSystemRegistry, columns: &[CatalogColumn], ) -> Result<IceDiskRelTableScanState, ParquetReaderError>
Scan the indices parquet file and return a streaming scan state.
Sourcepub fn scan_indptr(
&self,
vfs: &VirtualFileSystemRegistry,
columns: &[CatalogColumn],
) -> Result<Vec<Vec<Value>>, ParquetReaderError>
pub fn scan_indptr( &self, vfs: &VirtualFileSystemRegistry, columns: &[CatalogColumn], ) -> Result<Vec<Vec<Value>>, ParquetReaderError>
Scan the indptr parquet file (if using CSR layout).
Auto Trait Implementations§
impl Freeze for IceDiskRelTable
impl RefUnwindSafe for IceDiskRelTable
impl Send for IceDiskRelTable
impl Sync for IceDiskRelTable
impl Unpin for IceDiskRelTable
impl UnsafeUnpin for IceDiskRelTable
impl UnwindSafe for IceDiskRelTable
Blanket Implementations§
impl<T> Allocation for T
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
impl<ST, DT> CastableFrom<ST, Initialized, Initialized> for DT
impl<ST, DT> CastableFrom<ST, Uninit, Uninit> for DT
Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self> ⓘ
fn instrument(self, span: Span) -> Instrumented<Self> ⓘ
Source§fn in_current_span(self) -> Instrumented<Self> ⓘ
fn in_current_span(self) -> Instrumented<Self> ⓘ
Source§impl<T> IntoEither for T
impl<T> IntoEither for T
Source§fn into_either(self, into_left: bool) -> Either<Self, Self> ⓘ
fn into_either(self, into_left: bool) -> Either<Self, Self> ⓘ
Converts
self into a Left variant of Either<Self, Self>
if into_left is true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self> ⓘ
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self> ⓘ
Converts
self into a Left variant of Either<Self, Self>
if into_left(&self) returns true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read more