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/16 15:33:40 UTC

[arrow-datafusion] 02/02: clean up import

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

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

commit 8ed95e123646b67f798978e157a06f09eab76c11
Author: Jiayu Liu <ji...@hey.com>
AuthorDate: Wed Feb 16 23:32:20 2022 +0800

    clean up import
---
 datafusion-physical-expr/src/aggregate_expr.rs  | 12 ++++++------
 datafusion-physical-expr/src/physical_expr.rs   | 14 +++++++-------
 datafusion-physical-expr/src/window_expr.rs     | 10 +++++-----
 datafusion/src/physical_plan/expressions/mod.rs | 10 +++++-----
 datafusion/src/physical_plan/mod.rs             | 14 +++++++-------
 5 files changed, 30 insertions(+), 30 deletions(-)

diff --git a/datafusion-physical-expr/src/aggregate_expr.rs b/datafusion-physical-expr/src/aggregate_expr.rs
index c6ff312..428c09b 100644
--- a/datafusion-physical-expr/src/aggregate_expr.rs
+++ b/datafusion-physical-expr/src/aggregate_expr.rs
@@ -16,16 +16,16 @@
 // under the License.
 
 use crate::PhysicalExpr;
-use arrow::compute::kernels::partition::lexicographical_partition_ranges;
-use arrow::compute::kernels::sort::{SortColumn, SortOptions};
-use arrow::error::Result as ArrowResult;
-use arrow::{array::ArrayRef, datatypes::Field};
+
+
+
+use arrow::{datatypes::Field};
 use datafusion_common::Result;
 use datafusion_expr::Accumulator;
 use std::fmt::Debug;
-use std::ops::Range;
+
 use std::sync::Arc;
-use std::{any::Any, pin::Pin};
+use std::{any::Any};
 
 /// An aggregate expression that:
 /// * knows its resulting field
diff --git a/datafusion-physical-expr/src/physical_expr.rs b/datafusion-physical-expr/src/physical_expr.rs
index c9ab578..875c253 100644
--- a/datafusion-physical-expr/src/physical_expr.rs
+++ b/datafusion-physical-expr/src/physical_expr.rs
@@ -15,17 +15,17 @@
 // specific language governing permissions and limitations
 // under the License.
 
-use arrow::compute::kernels::sort::{SortColumn, SortOptions};
-use arrow::datatypes::{DataType, Schema, SchemaRef};
-use arrow::error::Result as ArrowResult;
+
+use arrow::datatypes::{DataType, Schema};
+
 use arrow::record_batch::RecordBatch;
-use arrow::{array::ArrayRef, datatypes::Field};
+
 use datafusion_common::Result;
-use datafusion_expr::Accumulator;
+
 use datafusion_expr::ColumnarValue;
 use std::fmt::{Debug, Display};
-use std::sync::Arc;
-use std::{any::Any, pin::Pin};
+
+use std::{any::Any};
 
 /// Expression that can be evaluated against a RecordBatch
 /// A Physical expression knows its type, nullability and how to evaluate itself.
diff --git a/datafusion-physical-expr/src/window_expr.rs b/datafusion-physical-expr/src/window_expr.rs
index 4d14aee..37f9dcf 100644
--- a/datafusion-physical-expr/src/window_expr.rs
+++ b/datafusion-physical-expr/src/window_expr.rs
@@ -18,17 +18,17 @@
 use crate::{PhysicalExpr, PhysicalSortExpr};
 use arrow::compute::kernels::partition::lexicographical_partition_ranges;
 use arrow::compute::kernels::sort::{SortColumn, SortOptions};
-use arrow::datatypes::{DataType, Schema, SchemaRef};
-use arrow::error::Result as ArrowResult;
+
+
 use arrow::record_batch::RecordBatch;
 use arrow::{array::ArrayRef, datatypes::Field};
 use datafusion_common::{DataFusionError, Result};
 use datafusion_expr::Accumulator;
-use datafusion_expr::ColumnarValue;
-use std::fmt::{Debug, Display};
+
+use std::fmt::{Debug};
 use std::ops::Range;
 use std::sync::Arc;
-use std::{any::Any, pin::Pin};
+use std::{any::Any};
 
 /// A window expression that:
 /// * knows its resulting field
diff --git a/datafusion/src/physical_plan/expressions/mod.rs b/datafusion/src/physical_plan/expressions/mod.rs
index c4a3c3e..abf4c19 100644
--- a/datafusion/src/physical_plan/expressions/mod.rs
+++ b/datafusion/src/physical_plan/expressions/mod.rs
@@ -17,13 +17,13 @@
 
 //! Defines physical expressions that can evaluated at runtime during query execution
 
-use std::sync::Arc;
+
 
 use super::ColumnarValue;
-use crate::error::{DataFusionError, Result};
-use crate::physical_plan::PhysicalExpr;
-use arrow::compute::kernels::sort::{SortColumn, SortOptions};
-use arrow::record_batch::RecordBatch;
+
+
+
+
 
 mod approx_distinct;
 mod approx_percentile_cont;
diff --git a/datafusion/src/physical_plan/mod.rs b/datafusion/src/physical_plan/mod.rs
index bed4bb3..b2f91e8 100644
--- a/datafusion/src/physical_plan/mod.rs
+++ b/datafusion/src/physical_plan/mod.rs
@@ -24,24 +24,24 @@ use self::{
 };
 use crate::physical_plan::expressions::PhysicalSortExpr;
 use crate::{
-    error::{DataFusionError, Result},
+    error::{Result},
     execution::runtime_env::RuntimeEnv,
     scalar::ScalarValue,
 };
-use arrow::compute::kernels::partition::lexicographical_partition_ranges;
-use arrow::compute::kernels::sort::{SortColumn, SortOptions};
-use arrow::datatypes::{DataType, Schema, SchemaRef};
+
+
+use arrow::datatypes::{SchemaRef};
 use arrow::error::Result as ArrowResult;
 use arrow::record_batch::RecordBatch;
-use arrow::{array::ArrayRef, datatypes::Field};
+
 use async_trait::async_trait;
 pub use datafusion_expr::Accumulator;
 pub use datafusion_expr::ColumnarValue;
 pub use display::DisplayFormatType;
 use futures::stream::Stream;
 use std::fmt;
-use std::fmt::{Debug, Display};
-use std::ops::Range;
+use std::fmt::{Debug};
+
 use std::sync::Arc;
 use std::task::{Context, Poll};
 use std::{any::Any, pin::Pin};