Struct RangePartitioning 

pub struct RangePartitioning { /* private fields */ }

Logical range partitioning.

RangePartitioning describes an ordered logical key space with split points.

• ordering defines the partitioning key and ordering using logical SortExprs.
• split_points define the boundaries between adjacent partitions.

Comparisons use the lexicographic order defined by ordering, including ASC/DESC and null ordering. Split points must be ordered according to that ordering, and each split point must have one value per ordering expression. See SplitPoint for the shared boundary contract.

The expressions are resolved against the declaring plan’s schema. This constructor does not validate split point value types against the resolved expression types. Like other user-specified data properties such as sortedness, if a source declares range partitioning, it is responsible for placing each row in the partition described by the split points. DataFusion will not validate this is upheld.

NOTE: Range-aware optimizer and execution behavior will be introduced incrementally. See https://github.com/apache/datafusion/issues/22395.

Implementations

impl RangePartitioning

pub fn try_new( ordering: Vec<SortExpr>, split_points: Vec<SplitPoint>, ) -> Result<Self>

Creates logical range partitioning metadata and validates split point shape and ordering.

pub fn partition_count(&self) -> usize

Return the number of partitions.

pub fn ordering(&self) -> &[SortExpr]

Returns the ordering that defines the range key.

pub fn split_points(&self) -> &[SplitPoint]

Returns the ordered split points between partitions.

Trait Implementations

impl Clone for RangePartitioning

fn clone(&self) -> RangePartitioning

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for RangePartitioning

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

Formats the value using the given formatter.

impl Display for RangePartitioning

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

Formats the value using the given formatter.

impl Eq for RangePartitioning

impl Hash for RangePartitioning

fn hash<__H: Hasher>(&self, state: &mut __H)

Feeds this value into the given Hasher.

fn hash_slice<H>(data: &[Self], state: &mut H)

where H: Hasher, Self: Sized,

Feeds a slice of this type into the given Hasher.

impl PartialEq for RangePartitioning

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

Equality operator ==.

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

Inequality operator !=.

impl PartialOrd for RangePartitioning

fn partial_cmp(&self, other: &RangePartitioning) -> Option<Ordering>

This method returns an ordering between self and other values if one exists.

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

Tests less than (for self and other) and is used by the < operator.

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

Tests less than or equal to (for self and other) and is used by the <= operator.

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

Tests greater than (for self and other) and is used by the > operator.

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

Tests greater than or equal to (for self and other) and is used by the >= operator.

impl StructuralPartialEq for RangePartitioning