Enum datafusion::physical_plan::Distribution

pub enum Distribution {
    UnspecifiedDistribution,
    SinglePartition,
    HashPartitioned(Vec<Arc<dyn PhysicalExpr>>),
}

Distribution schemes

Variants

UnspecifiedDistribution

Unspecified distribution

SinglePartition

A single partition is required

HashPartitioned(Vec<Arc<dyn PhysicalExpr>>)

Requires children to be distributed in such a way that the same values of the keys end up in the same partition

Implementations

impl Distribution

pub fn create_partitioning(&self, partition_count: usize) -> Partitioning

Creates a Partitioning for this Distribution to satisfy itself

Trait Implementations

impl Clone for Distribution

fn clone(&self) -> Distribution

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for Distribution

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

Formats the value using the given formatter.