pub struct ScanBuilder<D>where
D: ScanDriver,{ /* private fields */ }Expand description
A struct for building a scan operation.
Implementations§
Source§impl<D> ScanBuilder<D>where
D: ScanDriver,
impl<D> ScanBuilder<D>where
D: ScanDriver,
pub fn new( driver: D, layout: Layout, ctx: VTableContext<ArcRef<dyn EncodingVTable>>, ) -> ScanBuilder<D>
pub fn with_filter(self, filter: Arc<dyn VortexExpr>) -> ScanBuilder<D>
pub fn with_some_filter( self, filter: Option<Arc<dyn VortexExpr>>, ) -> ScanBuilder<D>
pub fn with_projection(self, projection: Arc<dyn VortexExpr>) -> ScanBuilder<D>
pub fn with_row_indices(self, row_indices: Buffer<u64>) -> ScanBuilder<D>
pub fn with_some_row_indices( self, row_indices: Option<Buffer<u64>>, ) -> ScanBuilder<D>
pub fn with_split_by(self, split_by: SplitBy) -> ScanBuilder<D>
Sourcepub fn with_canonicalize(self, canonicalize: bool) -> ScanBuilder<D>
pub fn with_canonicalize(self, canonicalize: bool) -> ScanBuilder<D>
Set whether the scan should canonicalize the output.
Sourcepub fn with_concurrency(self, concurrency: usize) -> ScanBuilder<D>
pub fn with_concurrency(self, concurrency: usize) -> ScanBuilder<D>
The number of row splits to make progress on concurrently, must be greater than 0.
pub fn with_task_executor(self, task_executor: TaskExecutor) -> ScanBuilder<D>
pub fn build(self) -> Result<Scan<D>, VortexError>
Sourcepub fn into_array_stream(
self,
) -> Result<impl ArrayStream + 'static, VortexError>
pub fn into_array_stream( self, ) -> Result<impl ArrayStream + 'static, VortexError>
Perform the scan operation and return a stream of arrays.
pub async fn into_array(self) -> Result<Arc<dyn Array>, VortexError>
Auto Trait Implementations§
impl<D> !Freeze for ScanBuilder<D>
impl<D> !RefUnwindSafe for ScanBuilder<D>
impl<D> Send for ScanBuilder<D>where
D: Send,
impl<D> Sync for ScanBuilder<D>where
D: Sync,
impl<D> Unpin for ScanBuilder<D>where
D: Unpin,
impl<D> !UnwindSafe for ScanBuilder<D>
Blanket Implementations§
Source§impl<T> ArchivePointee for T
impl<T> ArchivePointee for T
Source§type ArchivedMetadata = ()
type ArchivedMetadata = ()
The archived version of the pointer metadata for this type.
Source§fn pointer_metadata(
_: &<T as ArchivePointee>::ArchivedMetadata,
) -> <T as Pointee>::Metadata
fn pointer_metadata( _: &<T as ArchivePointee>::ArchivedMetadata, ) -> <T as Pointee>::Metadata
Converts some archived metadata to the pointer metadata for itself.
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> 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 moreSource§impl<T> LayoutRaw for T
impl<T> LayoutRaw for T
Source§fn layout_raw(_: <T as Pointee>::Metadata) -> Result<Layout, LayoutError>
fn layout_raw(_: <T as Pointee>::Metadata) -> Result<Layout, LayoutError>
Returns the layout of the type.
Source§impl<T, N1, N2> Niching<NichedOption<T, N1>> for N2
impl<T, N1, N2> Niching<NichedOption<T, N1>> for N2
Source§unsafe fn is_niched(niched: *const NichedOption<T, N1>) -> bool
unsafe fn is_niched(niched: *const NichedOption<T, N1>) -> bool
Returns whether the given value has been niched. Read more
Source§fn resolve_niched(out: Place<NichedOption<T, N1>>)
fn resolve_niched(out: Place<NichedOption<T, N1>>)
Writes data to
out indicating that a T is niched.