pub struct TableScanSplit { /* private fields */ }Expand description
A serializable full-table scan assignment for one shard snapshot.
Implementations§
Source§impl TableScanSplit
impl TableScanSplit
Sourcepub fn snapshot_id(&self) -> u64
pub fn snapshot_id(&self) -> u64
Return the global snapshot that assigned this shard.
Sourcepub fn shard_snapshot_id(&self) -> u64
pub fn shard_snapshot_id(&self) -> u64
Return this split’s shard snapshot identity.
Sourcepub fn create_scanner(&self, runtime: Config) -> Result<TableScanSplitScanner>
pub fn create_scanner(&self, runtime: Config) -> Result<TableScanSplitScanner>
Open this shard and return a typed full-scan iterator.
Sourcepub fn scanner_builder(&self, runtime: Config) -> TableScanSplitScannerBuilder
pub fn scanner_builder(&self, runtime: Config) -> TableScanSplitScannerBuilder
Start configuring a worker-local scanner for this split.
Trait Implementations§
Source§impl Clone for TableScanSplit
impl Clone for TableScanSplit
Source§impl<'de> Deserialize<'de> for TableScanSplit
impl<'de> Deserialize<'de> for TableScanSplit
Source§fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>where
__D: Deserializer<'de>,
fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>where
__D: Deserializer<'de>,
Deserialize this value from the given Serde deserializer. Read more
Auto Trait Implementations§
impl Freeze for TableScanSplit
impl RefUnwindSafe for TableScanSplit
impl Send for TableScanSplit
impl Sync for TableScanSplit
impl Unpin for TableScanSplit
impl UnsafeUnpin for TableScanSplit
impl UnwindSafe for TableScanSplit
Blanket Implementations§
impl<T> Allocation for T
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> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> DeserializeOwned for Twhere
T: for<'de> Deserialize<'de>,
impl<T> ErasedDestructor for Twhere
T: 'static,
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