diff --git a/core/src/execution/datafusion/expressions/stddev.rs b/core/src/execution/datafusion/expressions/stddev.rs index 73b2a6761..7214dbb26 100644 --- a/core/src/execution/datafusion/expressions/stddev.rs +++ b/core/src/execution/datafusion/expressions/stddev.rs @@ -17,18 +17,17 @@ //! Defines physical expressions that can evaluated at runtime during query execution -use std::any::Any; -use std::sync::Arc; - -use arrow::{array::ArrayRef, datatypes::DataType, datatypes::Field}; -use datafusion::logical_expr::Accumulator; -use datafusion_common::ScalarValue; -use datafusion_common::{internal_err, Result}; -use datafusion_physical_expr::{AggregateExpr, PhysicalExpr}; -use datafusion_physical_expr::expressions::format_state_name; -use crate::execution::datafusion::expressions::stats::StatsType; -use crate::execution::datafusion::expressions::utils::down_cast_any_ref; -use crate::execution::datafusion::expressions::variance::VarianceAccumulator; +use std::{any::Any, sync::Arc}; + +use crate::execution::datafusion::expressions::{ + stats::StatsType, utils::down_cast_any_ref, variance::VarianceAccumulator, +}; +use arrow::{ + array::ArrayRef, + datatypes::{DataType, Field}, +}; +use datafusion_common::{internal_err, Result, ScalarValue}; +use datafusion_physical_expr::{expressions::format_state_name, AggregateExpr, PhysicalExpr}; /// STDDEV and STDDEV_SAMP (standard deviation) aggregate expression /// The implementation mostly is the same as the DataFusion's implementation. The reason