You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@arrow.apache.org by ji...@apache.org on 2022/02/09 13:16:56 UTC

[arrow-datafusion] 03/03: remove reference to physical plan in logical plan

This is an automated email from the ASF dual-hosted git repository.

jiayuliu pushed a commit to branch logical-plan
in repository https://gitbox.apache.org/repos/asf/arrow-datafusion.git

commit b6d0cb7794b8dfd85567a3840ca7d42e3ea7cf1d
Author: Jiayu Liu <ji...@hey.com>
AuthorDate: Wed Feb 9 18:09:29 2022 +0800

    remove reference to physical plan in logical plan
---
 datafusion/src/logical_plan/expr.rs     | 3 +--
 datafusion/src/logical_plan/registry.rs | 6 ++----
 2 files changed, 3 insertions(+), 6 deletions(-)

diff --git a/datafusion/src/logical_plan/expr.rs b/datafusion/src/logical_plan/expr.rs
index ba853ee..f075aaa 100644
--- a/datafusion/src/logical_plan/expr.rs
+++ b/datafusion/src/logical_plan/expr.rs
@@ -22,8 +22,6 @@ pub use super::Operator;
 use crate::error::Result;
 use crate::logical_plan::ExprSchemable;
 use crate::logical_plan::{DFField, DFSchema};
-use crate::physical_plan::udaf::AggregateUDF;
-use crate::physical_plan::udf::ScalarUDF;
 use arrow::datatypes::DataType;
 use datafusion_common::DataFusionError;
 pub use datafusion_common::{Column, ExprSchema};
@@ -33,6 +31,7 @@ use datafusion_expr::BuiltinScalarFunction;
 pub use datafusion_expr::Expr;
 use datafusion_expr::StateTypeFunction;
 pub use datafusion_expr::{lit, lit_timestamp_nano, Literal};
+use datafusion_expr::{AggregateUDF, ScalarUDF};
 use datafusion_expr::{
     ReturnTypeFunction, ScalarFunctionImplementation, Signature, Volatility,
 };
diff --git a/datafusion/src/logical_plan/registry.rs b/datafusion/src/logical_plan/registry.rs
index d9b1839..f439a12 100644
--- a/datafusion/src/logical_plan/registry.rs
+++ b/datafusion/src/logical_plan/registry.rs
@@ -15,11 +15,9 @@
 // specific language governing permissions and limitations
 // under the License.
 
-use std::{collections::HashSet, sync::Arc};
-
 use crate::error::Result;
-use crate::physical_plan::udaf::AggregateUDF;
-use crate::physical_plan::udf::ScalarUDF;
+use datafusion_expr::{AggregateUDF, ScalarUDF};
+use std::{collections::HashSet, sync::Arc};
 
 /// A registry knows how to build logical expressions out of user-defined function' names
 pub trait FunctionRegistry {