pub struct AsyncPrefetchBuilder { /* private fields */ }Expand description
Builder for creating async prefetch datasets.
Implementations§
Source§impl AsyncPrefetchBuilder
impl AsyncPrefetchBuilder
Sourcepub fn batch_size(self, size: usize) -> Self
pub fn batch_size(self, size: usize) -> Self
Sets the batch size (rows per batch).
Sourcepub fn prefetch_size(self, size: usize) -> Self
pub fn prefetch_size(self, size: usize) -> Self
Sets the prefetch buffer size (number of batches).
Sourcepub fn from_parquet(
self,
path: impl AsRef<Path>,
) -> Result<AsyncPrefetchDataset>
pub fn from_parquet( self, path: impl AsRef<Path>, ) -> Result<AsyncPrefetchDataset>
Builds an async prefetch dataset from a Parquet file.
§Errors
Returns an error if the file cannot be opened.
Sourcepub fn from_source(self, source: Box<dyn DataSource>) -> AsyncPrefetchDataset
pub fn from_source(self, source: Box<dyn DataSource>) -> AsyncPrefetchDataset
Builds an async prefetch dataset from a data source.
Trait Implementations§
Source§impl Debug for AsyncPrefetchBuilder
impl Debug for AsyncPrefetchBuilder
Source§impl Default for AsyncPrefetchBuilder
impl Default for AsyncPrefetchBuilder
Source§fn default() -> AsyncPrefetchBuilder
fn default() -> AsyncPrefetchBuilder
Returns the “default value” for a type. Read more
Auto Trait Implementations§
impl Freeze for AsyncPrefetchBuilder
impl RefUnwindSafe for AsyncPrefetchBuilder
impl Send for AsyncPrefetchBuilder
impl Sync for AsyncPrefetchBuilder
impl Unpin for AsyncPrefetchBuilder
impl UnsafeUnpin for AsyncPrefetchBuilder
impl UnwindSafe for AsyncPrefetchBuilder
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> 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 moreCreates a shared type from an unshared type.