pub struct RowSeqScanNode {
pub table_desc: Option<StorageTableDesc>,
pub column_ids: Vec<i32>,
pub scan_ranges: Vec<ScanRange>,
pub vnode_bitmap: Option<Buffer>,
pub ordered: bool,
pub limit: Option<u64>,
pub as_of: Option<AsOf>,
}
Fields§
§table_desc: Option<StorageTableDesc>
§column_ids: Vec<i32>
§scan_ranges: Vec<ScanRange>
All the ranges need to be read. i.e., they are OR’ed.
Empty scan_ranges
means full table scan.
vnode_bitmap: Option<Buffer>
The partition to read for scan tasks.
Will be filled by the scheduler.
ordered: bool
Whether the order on output columns should be preserved.
limit: Option<u64>
The pushed down batch_limit
. Max rows needed to return.
as_of: Option<AsOf>
Implementations§
source§impl RowSeqScanNode
impl RowSeqScanNode
pub fn get_table_desc(&self) -> Result<&StorageTableDesc, PbFieldNotFound>
pub fn get_column_ids(&self) -> &Vec<i32>
pub fn get_scan_ranges(&self) -> &Vec<ScanRange>
pub fn get_vnode_bitmap(&self) -> Result<&Buffer, PbFieldNotFound>
pub fn get_ordered(&self) -> bool
pub fn get_limit(&self) -> Result<&u64, PbFieldNotFound>
pub fn get_as_of(&self) -> Result<&AsOf, PbFieldNotFound>
Trait Implementations§
source§impl Clone for RowSeqScanNode
impl Clone for RowSeqScanNode
source§fn clone(&self) -> RowSeqScanNode
fn clone(&self) -> RowSeqScanNode
Returns a copy of the value. Read more
1.0.0 · source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
Performs copy-assignment from
source
. Read moresource§impl Debug for RowSeqScanNode
impl Debug for RowSeqScanNode
source§impl Default for RowSeqScanNode
impl Default for RowSeqScanNode
source§impl<'de> Deserialize<'de> for RowSeqScanNode
impl<'de> Deserialize<'de> for RowSeqScanNode
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
source§impl Message for RowSeqScanNode
impl Message for RowSeqScanNode
source§fn encoded_len(&self) -> usize
fn encoded_len(&self) -> usize
Returns the encoded length of the message without a length delimiter.
source§fn encode(&self, buf: &mut impl BufMut) -> Result<(), EncodeError>where
Self: Sized,
fn encode(&self, buf: &mut impl BufMut) -> Result<(), EncodeError>where
Self: Sized,
Encodes the message to a buffer. Read more
source§fn encode_to_vec(&self) -> Vec<u8>where
Self: Sized,
fn encode_to_vec(&self) -> Vec<u8>where
Self: Sized,
Encodes the message to a newly allocated buffer.
source§fn encode_length_delimited(
&self,
buf: &mut impl BufMut,
) -> Result<(), EncodeError>where
Self: Sized,
fn encode_length_delimited(
&self,
buf: &mut impl BufMut,
) -> Result<(), EncodeError>where
Self: Sized,
Encodes the message with a length-delimiter to a buffer. Read more
source§fn encode_length_delimited_to_vec(&self) -> Vec<u8>where
Self: Sized,
fn encode_length_delimited_to_vec(&self) -> Vec<u8>where
Self: Sized,
Encodes the message with a length-delimiter to a newly allocated buffer.
source§fn decode(buf: impl Buf) -> Result<Self, DecodeError>where
Self: Default,
fn decode(buf: impl Buf) -> Result<Self, DecodeError>where
Self: Default,
Decodes an instance of the message from a buffer. Read more
source§fn decode_length_delimited(buf: impl Buf) -> Result<Self, DecodeError>where
Self: Default,
fn decode_length_delimited(buf: impl Buf) -> Result<Self, DecodeError>where
Self: Default,
Decodes a length-delimited instance of the message from the buffer.
source§fn merge(&mut self, buf: impl Buf) -> Result<(), DecodeError>where
Self: Sized,
fn merge(&mut self, buf: impl Buf) -> Result<(), DecodeError>where
Self: Sized,
Decodes an instance of the message from a buffer, and merges it into
self
. Read moresource§fn merge_length_delimited(&mut self, buf: impl Buf) -> Result<(), DecodeError>where
Self: Sized,
fn merge_length_delimited(&mut self, buf: impl Buf) -> Result<(), DecodeError>where
Self: Sized,
Decodes a length-delimited instance of the message from buffer, and
merges it into
self
.source§impl PartialEq for RowSeqScanNode
impl PartialEq for RowSeqScanNode
source§impl Serialize for RowSeqScanNode
impl Serialize for RowSeqScanNode
impl StructuralPartialEq for RowSeqScanNode
Auto Trait Implementations§
impl Freeze for RowSeqScanNode
impl RefUnwindSafe for RowSeqScanNode
impl Send for RowSeqScanNode
impl Sync for RowSeqScanNode
impl Unpin for RowSeqScanNode
impl UnwindSafe for RowSeqScanNode
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> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
source§unsafe fn clone_to_uninit(&self, dst: *mut T)
unsafe fn clone_to_uninit(&self, dst: *mut T)
🔬This is a nightly-only experimental API. (
clone_to_uninit
)§impl<T> Instrument for T
impl<T> Instrument for T
§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
source§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