pub struct ScanPartitioner { /* private fields */ }Expand description
Parallel scan partitioner
Implementations§
Source§impl ScanPartitioner
impl ScanPartitioner
Sourcepub fn partition_range(&self, partition_id: usize) -> (usize, usize)
pub fn partition_range(&self, partition_id: usize) -> (usize, usize)
Get partition range for a given partition ID
Sourcepub fn is_valid_partition(&self, partition_id: usize) -> bool
pub fn is_valid_partition(&self, partition_id: usize) -> bool
Check if partition is valid
Auto Trait Implementations§
impl Freeze for ScanPartitioner
impl RefUnwindSafe for ScanPartitioner
impl Send for ScanPartitioner
impl Sync for ScanPartitioner
impl Unpin for ScanPartitioner
impl UnwindSafe for ScanPartitioner
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 moreSource§impl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
Source§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
Wrap the input message
T in a tonic::Request