Struct lance_encoding::encodings::logical::binary::BinaryPageScheduler
source · pub struct BinaryPageScheduler { /* private fields */ }
Expand description
A logical scheduler for utf8/binary pages which assumes the data are encoded as List
Implementations§
source§impl BinaryPageScheduler
impl BinaryPageScheduler
pub fn new( varbin_scheduler: Box<dyn LogicalPageScheduler>, data_type: DataType ) -> Self
Trait Implementations§
source§impl Debug for BinaryPageScheduler
impl Debug for BinaryPageScheduler
source§impl LogicalPageScheduler for BinaryPageScheduler
impl LogicalPageScheduler for BinaryPageScheduler
source§fn schedule_ranges(
&self,
ranges: &[Range<u32>],
scheduler: &Arc<dyn EncodingsIo>,
sink: &UnboundedSender<Box<dyn LogicalPageDecoder>>
) -> Result<()>
fn schedule_ranges( &self, ranges: &[Range<u32>], scheduler: &Arc<dyn EncodingsIo>, sink: &UnboundedSender<Box<dyn LogicalPageDecoder>> ) -> Result<()>
Schedules I/O for the requested portions of the page. Read more
source§fn schedule_take(
&self,
indices: &[u32],
scheduler: &Arc<dyn EncodingsIo>,
sink: &UnboundedSender<Box<dyn LogicalPageDecoder>>
) -> Result<()>
fn schedule_take( &self, indices: &[u32], scheduler: &Arc<dyn EncodingsIo>, sink: &UnboundedSender<Box<dyn LogicalPageDecoder>> ) -> Result<()>
Schedules I/O for the requested rows (identified by row offsets from start of page)
TODO: implement this using schedule_ranges
Auto Trait Implementations§
impl Freeze for BinaryPageScheduler
impl !RefUnwindSafe for BinaryPageScheduler
impl Send for BinaryPageScheduler
impl Sync for BinaryPageScheduler
impl Unpin for BinaryPageScheduler
impl !UnwindSafe for BinaryPageScheduler
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 more