pub struct TableScanPlan { /* private fields */ }Expand description
A serializable, fixed global-snapshot scan plan for one typed table.
A plan does not retain the snapshot against expiration; applications keep the referenced global and shard snapshots available for their workers.
Implementations§
Source§impl TableScanPlan
impl TableScanPlan
Sourcepub fn snapshot_id(&self) -> u64
pub fn snapshot_id(&self) -> u64
Return the fixed global snapshot selected for this scan.
Sourcepub fn total_buckets(&self) -> u32
pub fn total_buckets(&self) -> u32
Return the bucket count fixed by the global snapshot.
Sourcepub fn schema(&self) -> &TableSchema
pub fn schema(&self) -> &TableSchema
Return the schema fixed into this plan.
Sourcepub fn data_size_bytes(&self) -> u64
pub fn data_size_bytes(&self) -> u64
Return the total encoded data size reported by all shard snapshots.
Sourcepub fn splits(&self) -> Result<Vec<TableScanSplit>>
pub fn splits(&self) -> Result<Vec<TableScanSplit>>
Produce one independently serializable split per shard snapshot.
Trait Implementations§
Source§impl Clone for TableScanPlan
impl Clone for TableScanPlan
Source§impl<'de> Deserialize<'de> for TableScanPlan
impl<'de> Deserialize<'de> for TableScanPlan
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 TableScanPlan
impl RefUnwindSafe for TableScanPlan
impl Send for TableScanPlan
impl Sync for TableScanPlan
impl Unpin for TableScanPlan
impl UnsafeUnpin for TableScanPlan
impl UnwindSafe for TableScanPlan
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