datafusion_physical_expr/
lib.rs1#![doc(
19 html_logo_url = "https://raw.githubusercontent.com/apache/datafusion/19fe44cf2f30cbdd63d4a4f52c74055163c6cc38/docs/logos/standalone_logo/logo_original.svg",
20 html_favicon_url = "https://raw.githubusercontent.com/apache/datafusion/19fe44cf2f30cbdd63d4a4f52c74055163c6cc38/docs/logos/standalone_logo/logo_original.svg"
21)]
22#![cfg_attr(docsrs, feature(doc_cfg))]
23#![deny(clippy::clone_on_ref_ptr)]
26#![cfg_attr(test, allow(clippy::needless_pass_by_value))]
27
28pub mod aggregate;
30pub mod analysis;
31pub mod binary_map {
32 pub use datafusion_physical_expr_common::binary_map::{ArrowBytesSet, OutputType};
33}
34pub mod async_scalar_function;
35pub mod equivalence;
36pub mod expressions;
37pub mod higher_order_function;
38pub mod intervals;
39mod partitioning;
40mod physical_expr;
41pub mod planner;
42pub mod projection;
43#[cfg(all(test, feature = "proto"))]
45pub(crate) mod proto_test_util;
46mod scalar_function;
47pub mod scalar_subquery;
48pub mod simplifier;
49pub mod statistics;
50pub mod utils;
51pub mod window;
52
53pub mod execution_props {
55 pub use datafusion_expr::execution_props::ExecutionProps;
56 pub use datafusion_expr::var_provider::{VarProvider, VarType};
57}
58
59pub use aggregate::groups_accumulator::{GroupsAccumulatorAdapter, NullState};
60pub use analysis::{AnalysisContext, ExprBoundaries, analyze};
61pub use datafusion_common::SplitPoint;
62pub use equivalence::{
63 AcrossPartitions, ConstExpr, EquivalenceProperties, calculate_union,
64};
65pub use expressions::{DynamicFilterTracker, DynamicFilterTracking};
66pub use partitioning::{
67 Distribution, Partitioning, PartitioningSatisfaction, RangePartitioning,
68};
69pub use physical_expr::{
70 add_offset_to_expr, add_offset_to_physical_sort_exprs, create_lex_ordering,
71 create_ordering, create_physical_partitioning, create_physical_sort_expr,
72 create_physical_sort_exprs, physical_exprs_bag_equal, physical_exprs_contains,
73 physical_exprs_equal,
74};
75
76pub use datafusion_physical_expr_common::physical_expr::{PhysicalExpr, PhysicalExprRef};
77pub use datafusion_physical_expr_common::sort_expr::{
78 LexOrdering, LexRequirement, OrderingRequirements, PhysicalSortExpr,
79 PhysicalSortRequirement,
80};
81
82pub use higher_order_function::HigherOrderFunctionExpr;
83pub use planner::{create_physical_expr, create_physical_exprs};
84pub use scalar_function::ScalarFunctionExpr;
85pub use simplifier::PhysicalExprSimplifier;
86pub use utils::{conjunction, conjunction_opt, split_conjunction};
87
88pub mod tree_node {
90 pub use datafusion_physical_expr_common::tree_node::ExprContext;
91}