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};