[arrow-datafusion] branch master updated: Deprecate legacy datafusion::logical_plan module (#3338)

[alamb]

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

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


The following commit(s) were added to refs/heads/master by this push:
     new 93a95c25f Deprecate legacy datafusion::logical_plan module (#3338)
93a95c25f is described below

commit 93a95c25fd04100185f6e7dd735635eaa7d5613e
Author: Andy Grove <andygrov...@gmail.com>
AuthorDate: Sat Sep 3 03:42:38 2022 -0600

    Deprecate legacy datafusion::logical_plan module (#3338)
---
 datafusion/core/src/dataframe.rs                  |  6 +++---
 datafusion/core/src/datasource/listing/helpers.rs | 14 +++++++-------
 datafusion/core/src/lib.rs                        |  3 +++
 datafusion/core/src/physical_optimizer/pruning.rs |  4 +---
 4 files changed, 14 insertions(+), 13 deletions(-)

diff --git a/datafusion/core/src/dataframe.rs b/datafusion/core/src/dataframe.rs
index 8f2759f53..3c77f1671 100644
--- a/datafusion/core/src/dataframe.rs
+++ b/datafusion/core/src/dataframe.rs
@@ -805,12 +805,12 @@ mod tests {
     use super::*;
     use crate::execution::options::CsvReadOptions;
     use crate::physical_plan::ColumnarValue;
+    use crate::test_util;
     use crate::{assert_batches_sorted_eq, execution::context::SessionContext};
-    use crate::{logical_plan::*, test_util};
     use arrow::datatypes::DataType;
-    use datafusion_expr::{cast, Volatility};
     use datafusion_expr::{
-        BuiltInWindowFunction, ScalarFunctionImplementation, WindowFunction,
+        avg, cast, count, count_distinct, create_udf, lit, max, min, sum,
+        BuiltInWindowFunction, ScalarFunctionImplementation, Volatility, 
WindowFunction,
     };
 
     #[tokio::test]
diff --git a/datafusion/core/src/datasource/listing/helpers.rs 
b/datafusion/core/src/datasource/listing/helpers.rs
index 6f96ddbea..e75fb089f 100644
--- a/datafusion/core/src/datasource/listing/helpers.rs
+++ b/datafusion/core/src/datasource/listing/helpers.rs
@@ -32,17 +32,17 @@ use futures::{stream::BoxStream, TryStreamExt};
 use log::debug;
 
 use crate::{
-    datasource::MemTable,
-    error::Result,
-    execution::context::SessionContext,
-    logical_plan::{self, Expr, ExprVisitable, ExpressionVisitor, Recursion},
+    datasource::MemTable, error::Result, execution::context::SessionContext,
     scalar::ScalarValue,
 };
 
 use super::PartitionedFile;
 use crate::datasource::listing::ListingTableUrl;
-use datafusion_common::DataFusionError;
-use datafusion_expr::Volatility;
+use datafusion_common::{Column, DataFusionError};
+use datafusion_expr::{
+    expr_visitor::{ExprVisitable, ExpressionVisitor, Recursion},
+    Expr, Volatility,
+};
 use object_store::path::Path;
 use object_store::{ObjectMeta, ObjectStore};
 
@@ -74,7 +74,7 @@ impl ApplicabilityVisitor<'_> {
 impl ExpressionVisitor for ApplicabilityVisitor<'_> {
     fn pre_visit(self, expr: &Expr) -> Result<Recursion<Self>> {
         let rec = match expr {
-            Expr::Column(logical_plan::Column { ref name, .. }) => {
+            Expr::Column(Column { ref name, .. }) => {
                 *self.is_applicable &= self.col_names.contains(name);
                 Recursion::Stop(self) // leaf node anyway
             }
diff --git a/datafusion/core/src/lib.rs b/datafusion/core/src/lib.rs
index 0dd665628..f5b8cf431 100644
--- a/datafusion/core/src/lib.rs
+++ b/datafusion/core/src/lib.rs
@@ -215,6 +215,9 @@ pub mod dataframe;
 pub mod datasource;
 pub mod error;
 pub mod execution;
+#[deprecated]
+// logical_plan module just contains re-exports and will be removed in a 
future release
+// https://github.com/apache/arrow-datafusion/issues/2683
 pub mod logical_plan;
 pub mod physical_optimizer;
 pub mod physical_plan;
diff --git a/datafusion/core/src/physical_optimizer/pruning.rs 
b/datafusion/core/src/physical_optimizer/pruning.rs
index d41a1137d..bad67b0cf 100644
--- a/datafusion/core/src/physical_optimizer/pruning.rs
+++ b/datafusion/core/src/physical_optimizer/pruning.rs
@@ -662,12 +662,10 @@ fn build_predicate_expression(
     schema: &Schema,
     required_columns: &mut RequiredStatColumns,
 ) -> Result<Expr> {
-    use crate::logical_plan;
-
     // Returned for unsupported expressions. Such expressions are
     // converted to TRUE. This can still be useful when multiple
     // conditions are joined using AND such as: column > 10 AND TRUE
-    let unhandled = logical_plan::lit(true);
+    let unhandled = lit(true);
 
     // predicate expression can only be a binary expression
     let (left, op, right) = match expr {