pub struct ObjectStoreRowMetadataSource { /* private fields */ }Expand description
A RowMetadataSource that uses an object storage API to retrieve
partition columns and timestamp metadata.
Object store metadata by default comes from FileMetadata, but
may be overridden with a custom TableProvider using
Self::with_file_metadata.
Implementations§
Source§impl ObjectStoreRowMetadataSource
impl ObjectStoreRowMetadataSource
Sourcepub fn new(file_metadata: Arc<FileMetadata>) -> Self
pub fn new(file_metadata: Arc<FileMetadata>) -> Self
Create a new ObjectStoreRowMetadataSource from the FileMetadata table
Sourcepub fn with_file_metadata(file_metadata: Arc<dyn TableProvider>) -> Self
pub fn with_file_metadata(file_metadata: Arc<dyn TableProvider>) -> Self
Create a new ObjectStoreRowMetadataSource using a custom file metadata source
Trait Implementations§
Source§impl Clone for ObjectStoreRowMetadataSource
impl Clone for ObjectStoreRowMetadataSource
Source§fn clone(&self) -> ObjectStoreRowMetadataSource
fn clone(&self) -> ObjectStoreRowMetadataSource
Returns a duplicate of the value. Read more
1.0.0 · Source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
Performs copy-assignment from
source. Read moreSource§impl Debug for ObjectStoreRowMetadataSource
impl Debug for ObjectStoreRowMetadataSource
Source§impl RowMetadataSource for ObjectStoreRowMetadataSource
impl RowMetadataSource for ObjectStoreRowMetadataSource
Source§fn row_metadata(
&self,
table: ResolvedTableReference,
scan: &TableScan,
) -> Result<LogicalPlanBuilder>
fn row_metadata( &self, table: ResolvedTableReference, scan: &TableScan, ) -> Result<LogicalPlanBuilder>
Scan for partition column values using object store metadata. This allows us to efficiently scan for distinct partition column values without ever reading from a table directly, which is useful for low-overhead incremental view maintenance.
Auto Trait Implementations§
impl Freeze for ObjectStoreRowMetadataSource
impl !RefUnwindSafe for ObjectStoreRowMetadataSource
impl Send for ObjectStoreRowMetadataSource
impl Sync for ObjectStoreRowMetadataSource
impl Unpin for ObjectStoreRowMetadataSource
impl !UnwindSafe for ObjectStoreRowMetadataSource
Blanket Implementations§
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
Source§impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
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