Enum datafusion_physical_expr::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

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

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

UnknownPartitioning(usize)

Unknown partitioning scheme with a known number of partitions

Implementations

impl Partitioning

pub fn partition_count(&self) -> usize

Returns the number of partitions in this partitioning scheme

pub fn satisfy<F: FnOnce() -> EquivalenceProperties>( &self, required: Distribution, equal_properties: F ) -> bool

Returns true when the guarantees made by this [Partitioning] are sufficient to satisfy the partitioning scheme mandated by the required [Distribution]

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.

impl Display for Partitioning

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

Formats the value using the given formatter.

impl PartialEq<Partitioning> for Partitioning

fn eq(&self, other: &Partitioning) -> bool

This method tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

This method tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.