pub struct DeltaScanBuilder<'table> { /* private fields */ }Expand description
Configures one single-use direct Delta scan.
Implementations§
Source§impl<'table> DeltaScanBuilder<'table>
impl<'table> DeltaScanBuilder<'table>
Sourcepub fn with_projection(self, logical_columns: Vec<String>) -> Self
pub fn with_projection(self, logical_columns: Vec<String>) -> Self
Selects visible logical columns in caller order.
Sourcepub fn with_predicate(self, predicate: DeltaPredicate) -> Self
pub fn with_predicate(self, predicate: DeltaPredicate) -> Self
Replaces the exact logical row predicate.
Sourcepub const fn with_limit(self, limit: usize) -> Self
pub const fn with_limit(self, limit: usize) -> Self
Sets the maximum number of output rows.
Sourcepub fn with_target_partitions(
self,
value: usize,
) -> Result<Self, DeltaReaderError>
pub fn with_target_partitions( self, value: usize, ) -> Result<Self, DeltaReaderError>
Overrides the number of planned scan partitions.
Sourcepub fn with_execution_options(
self,
value: DeltaReaderExecutionOptions,
) -> Result<Self, DeltaReaderError>
pub fn with_execution_options( self, value: DeltaReaderExecutionOptions, ) -> Result<Self, DeltaReaderError>
Replaces the execution settings for this scan.
Sourcepub async fn build(self) -> Result<DeltaScan, DeltaReaderError>
pub async fn build(self) -> Result<DeltaScan, DeltaReaderError>
Builds one immutable single-use scan plan without reading data files.
Auto Trait Implementations§
impl<'table> !RefUnwindSafe for DeltaScanBuilder<'table>
impl<'table> !UnwindSafe for DeltaScanBuilder<'table>
impl<'table> Freeze for DeltaScanBuilder<'table>
impl<'table> Send for DeltaScanBuilder<'table>
impl<'table> Sync for DeltaScanBuilder<'table>
impl<'table> Unpin for DeltaScanBuilder<'table>
impl<'table> UnsafeUnpin for DeltaScanBuilder<'table>
Blanket Implementations§
Source§impl<T> AsAny for T
impl<T> AsAny for T
Source§fn any_ref(&self) -> &(dyn Any + Sync + Send + 'static)
fn any_ref(&self) -> &(dyn Any + Sync + Send + 'static)
Obtains a
dyn Any reference to the object: Read moreSource§fn as_any(self: Arc<T>) -> Arc<dyn Any + Sync + Send> ⓘ
fn as_any(self: Arc<T>) -> Arc<dyn Any + Sync + Send> ⓘ
Obtains an
Arc<dyn Any> reference to the object: Read moreSource§fn into_any(self: Box<T>) -> Box<dyn Any + Sync + Send>
fn into_any(self: Box<T>) -> Box<dyn Any + Sync + Send>
Converts the object to
Box<dyn Any>: Read moreSource§fn type_name(&self) -> &'static str
fn type_name(&self) -> &'static str
Convenient wrapper for
std::any::type_name, since Any does not provide it and
Any::type_id is useless as a debugging aid (its Debug is just a mess of hex digits).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