Struct TableDistribution

pub struct TableDistribution {
    compute_vnode: ComputeVnode,
}

Represents the distribution for a specific table instance.

Fields

compute_vnode: ComputeVnode

The way to compute vnode provided primary key

Implementations

impl TableDistribution

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

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

pub fn is_singleton(&self) -> bool

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

Distribution that accesses all vnodes, mainly used for tests.

pub fn singleton() -> Self

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

Formats the value using the given formatter.