Enum datafusion::physical_plan::Partitioning

pub enum Partitioning {
    RoundRobinBatch(usize),
    Hash(Vec<Arc<dyn PhysicalExpr>>, usize),
    UnknownPartitioning(usize),
}

Partitioning schemes supported by operators.

Variants

RoundRobinBatch(usize)

Allocate batches using a round-robin algorithm and the specified number of partitions

Tuple Fields of RoundRobinBatch

0: usize

Hash(Vec<Arc<dyn PhysicalExpr>>, usize)

Allocate rows based on a hash of one of more expressions and the specified number of partitions

Tuple Fields of Hash

0: Vec<Arc<dyn PhysicalExpr>>1: usize

UnknownPartitioning(usize)

Unknown partitioning scheme with a known number of partitions

Tuple Fields of UnknownPartitioning

0: usize

Implementations

impl Partitioning

pub fn partition_count(&self) -> usize

Returns the number of partitions in this partitioning scheme

Trait Implementations

impl Clone for Partitioning

fn clone(&self) -> Partitioning

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for Partitioning

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

Formats the value using the given formatter.