Struct TableDistribution

pub struct TableDistribution {
    compute_vnode: ComputeVnode,
}

Represents the distribution for a specific table instance.

Fields

compute_vnode: ComputeVnode

Implementations

impl TableDistribution

pub fn new_from_storage_table_desc( vnodes: Option<Arc<Bitmap>>, table_desc: &StorageTableDesc, ) -> TableDistribution

pub fn new( vnodes: Option<Arc<Bitmap>>, dist_key_in_pk_indices: Vec<usize>, vnode_col_idx_in_pk: Option<usize>, ) -> TableDistribution

pub fn is_singleton(&self) -> bool

pub fn all( dist_key_in_pk_indices: Vec<usize>, vnode_count: usize, ) -> TableDistribution

Distribution that accesses all vnodes, mainly used for tests.

pub fn singleton() -> TableDistribution

Fallback distribution for singleton or tests.

pub fn update_vnode_bitmap(&mut self, new_vnodes: Arc<Bitmap>) -> Arc<Bitmap>

pub fn vnodes(&self) -> &Arc<Bitmap>

Get vnode bitmap if distributed, or a dummy [Bitmap::singleton()] if singleton.

pub fn vnode_count(&self) -> usize

Get vnode count (1 if singleton). Equivalent to self.vnodes().len().

pub fn compute_vnode_by_pk(&self, pk: impl Row) -> VirtualNode

Get vnode value with given primary key.

pub fn try_compute_vnode_by_pk_prefix( &self, pk_prefix: impl Row, ) -> Option<VirtualNode>

impl TableDistribution

pub fn compute_chunk_vnode( &self, chunk: &DataChunk, pk_indices: &[usize], ) -> Vec<VirtualNode>

Get vnode values with indices on the given chunk.

Vnode of invisible rows will be included. Only the vnode of visible row check if it’s accessible

Trait Implementations

impl Clone for TableDistribution

fn clone(&self) -> TableDistribution

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for TableDistribution

fn fmt(&self, f: &mut Formatter<'_>) -> Result<(), Error>

Formats the value using the given formatter.