Skip to content

Commit cad5e05

Browse files
Add range partitioning metadata
1 parent e8777a0 commit cad5e05

12 files changed

Lines changed: 853 additions & 212 deletions

File tree

datafusion/ffi/src/physical_expr/partitioning.rs

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -45,8 +45,10 @@ impl From<&Partitioning> for FFI_Partitioning {
4545
.collect();
4646
Self::Hash(exprs, *size)
4747
}
48-
// FFI does not yet expose expression partition metadata.
49-
Partitioning::Expr(expr) => Self::UnknownPartitioning(expr.partition_count()),
48+
// FFI does not yet expose range partition metadata.
49+
Partitioning::Range(range) => {
50+
Self::UnknownPartitioning(range.partition_count())
51+
}
5052
Partitioning::UnknownPartitioning(size) => Self::UnknownPartitioning(*size),
5153
}
5254
}

datafusion/physical-expr/src/lib.rs

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -58,7 +58,10 @@ pub use analysis::{AnalysisContext, ExprBoundaries, analyze};
5858
pub use equivalence::{
5959
AcrossPartitions, ConstExpr, EquivalenceProperties, calculate_union,
6060
};
61-
pub use partitioning::{Distribution, ExprPartitioning, Partitioning};
61+
pub use partitioning::{
62+
Distribution, Partitioning, RangeBound, RangeInterval, RangePartition,
63+
RangePartitioning,
64+
};
6265
pub use physical_expr::{
6366
add_offset_to_expr, add_offset_to_physical_sort_exprs, create_lex_ordering,
6467
create_ordering, create_physical_sort_expr, create_physical_sort_exprs,

0 commit comments

Comments
 (0)