// SPDX-License-Identifier: Apache-2.0

// SPDX-FileCopyrightText: See the NOTICE file distributed with this work for additional information regarding copyright ownership

// SPDX-FileContributor: Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements

#![doc(

html_logo_url = "https://raw.githubusercontent.com/apache/datafusion/19fe44cf2f30cbdd63d4a4f52c74055163c6cc38/docs/logos/standalone_logo/logo_original.svg",

html_favicon_url = "https://raw.githubusercontent.com/apache/datafusion/19fe44cf2f30cbdd63d4a4f52c74055163c6cc38/docs/logos/standalone_logo/logo_original.svg"

)]

#![cfg_attr(docsrs, feature(doc_cfg))]

// Make sure fast / cheap clones on Arc are explicit:

// https://github.com/apache/datafusion/issues/11143

#![deny(clippy::clone_on_ref_ptr)]

#![cfg_attr(test, allow(clippy::needless_pass_by_value))]

//! [DataFusion](https://github.com/apache/datafusion)

//! is an extensible query execution framework that uses

//! [Apache Arrow](https://arrow.apache.org) as its in-memory format.

//!

//! This crate is a submodule of DataFusion that provides types representing

//! logical query plans ([LogicalPlan]) and logical expressions ([Expr]) as well as utilities for

//! working with these types.

//!

//! The [expr_fn] module contains functions for creating expressions.

extern crate core;

mod higher_order_function;

mod literal;

mod operation;

mod partition_evaluator;

mod table_source;

mod udaf;

mod udf;

mod udwf;

pub mod arguments;

pub mod conditional_expressions;

pub mod execution_props;

pub mod expr;

pub mod expr_fn;

pub mod expr_rewriter;

pub mod expr_schema;

pub mod extension_types;

pub mod function;

pub mod physical_planning_context;

pub mod select_expr;

pub mod groups_accumulator {

pub use datafusion_expr_common::groups_accumulator::*;

}

pub mod interval_arithmetic {

pub use datafusion_expr_common::interval_arithmetic::*;

}

pub mod logical_plan;

pub mod dml {

//! DML (Data Manipulation Language) types for DELETE, UPDATE operations.

pub use crate::logical_plan::dml::*;

}

pub mod planner;

/// Protobuf conversions for [`WindowFrame`], [`WindowFrameBound`],

/// [`WindowFrameUnits`], [`MergeIntoClauseKind`] and

/// [`NullTreatment`](expr::NullTreatment), gated on the `proto` feature.

#[cfg(feature = "proto")]

mod proto;

pub mod registry;

pub mod simplify;

pub mod sort_properties {

pub use datafusion_expr_common::sort_properties::*;

}

pub mod async_udf;

pub mod statistics {

pub use datafusion_expr_common::statistics::*;

}

mod predicate_bounds;

pub mod preimage;

pub mod ptr_eq;

#[cfg(not(feature = "sql"))]

pub mod sql;

/// # Public Only for Internal Use:

///

/// This is not a public API and is for internal use only; see [API policy] for details.

///

/// [API policy]: https://datafusion.apache.org/contributor-guide/api-health.html#internal-public-apis

#[doc(hidden)]

pub mod test;

pub mod tree_node;

pub mod type_coercion;

pub mod udf_eq;

pub mod utils;

pub mod var_provider;

pub mod window_frame;

pub mod window_state;

pub use datafusion_doc::{

DocSection, Documentation, DocumentationBuilder, aggregate_doc_sections,

scalar_doc_sections, window_doc_sections,

};

pub use datafusion_expr_common::accumulator::{

Accumulator, AggregateMetric, AggregateMetricRecorder, AggregateMetrics,

};

pub use datafusion_expr_common::columnar_value::ColumnarValue;

pub use datafusion_expr_common::groups_accumulator::{

EmitTo, GroupSelection, GroupsAccumulator,

};

pub use datafusion_expr_common::operator::Operator;

pub use datafusion_expr_common::placement::ExpressionPlacement;

pub use datafusion_expr_common::signature::{

ArrayFunctionArgument, ArrayFunctionSignature, Coercion, EncodingPreservation,

Signature, TIMEZONE_WILDCARD, TypeSignature, TypeSignatureClass, Volatility,

};

pub use datafusion_expr_common::type_coercion::binary;

pub use expr::{

Between, BinaryExpr, Case, Cast, Expr, GetFieldAccess, GroupingSet, Like,

Sort as SortExpr, TryCast, WindowFunctionDefinition,

};

pub use expr_fn::*;

pub use expr_schema::ExprSchemable;

pub use function::{

AccumulatorFactoryFunction, PartitionEvaluatorFactory, ReturnTypeFunction,

ScalarFunctionImplementation, StateTypeFunction,

};

pub use higher_order_function::{

HigherOrderFunctionArgs, HigherOrderReturnFieldArgs, HigherOrderSignature,

HigherOrderTypeSignature, HigherOrderUDF, HigherOrderUDFImpl, LambdaArgument,

LambdaParametersProgress, ValueOrLambda,

};

pub use literal::{

Literal, TimestampLiteral, lit, lit_timestamp_nano, lit_with_metadata,

};

pub use logical_plan::*;

pub use partition_evaluator::PartitionEvaluator;

#[cfg(feature = "sql")]

pub use sqlparser;

pub use table_source::{TableProviderFilterPushDown, TableSource, TableType};

pub use udaf::{

AggregateUDF, AggregateUDFImpl, DistinctHandling, ReversedUDAF, SetMonotonicity,

StatisticsArgs, UdafDisplayNameBuilder, UdafHumanDisplayBuilder,

UdafSchemaNameBuilder, UdafWindowFunctionDisplayNameBuilder,

UdafWindowFunctionSchemaNameBuilder, udaf_default_return_field,

udaf_return_field_preserving_arg_metadata,

};

#[expect(deprecated)]

pub use udaf::{

udaf_default_display_name, udaf_default_human_display, udaf_default_schema_name,

udaf_default_window_function_display_name, udaf_default_window_function_schema_name,

};

pub use udf::{

ReturnFieldArgs, ScalarFunctionArgs, ScalarUDF, ScalarUDFImpl, StructFieldMapping,

};

pub use udwf::{LimitEffect, ReversedUDWF, WindowUDF, WindowUDFImpl};

pub use window_frame::{WindowFrame, WindowFrameBound, WindowFrameUnits};

#[cfg(test)]

#[ctor::ctor(unsafe)]

fn init() {

// Enable RUST_LOG logging configuration for test

let _ = env_logger::try_init();

}