Enum datafusion_expr::logical_plan::Partitioning

pub enum Partitioning {
    RoundRobinBatch(usize),
    Hash(Vec<Expr>, usize),
    DistributeBy(Vec<Expr>),
}

Logical partitioning schemes supported by the repartition operator.

Variants

RoundRobinBatch(usize)

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

Hash(Vec<Expr>, usize)

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

DistributeBy(Vec<Expr>)

The DISTRIBUTE BY clause is used to repartition the data based on the input expressions

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.