Skip to content

Commit a9b5fae

Browse files
committed
style(cubestore): Ran cargo fmt
1 parent 89ce6b7 commit a9b5fae

File tree

1 file changed

+9
-2
lines changed
  • rust/cubestore/cubestore/src/metastore

1 file changed

+9
-2
lines changed

rust/cubestore/cubestore/src/metastore/table.rs

Lines changed: 9 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -11,7 +11,9 @@ use byteorder::{BigEndian, WriteBytesExt};
1111
use chrono::DateTime;
1212
use chrono::Utc;
1313
use datafusion::arrow::datatypes::Schema as ArrowSchema;
14-
use datafusion::physical_plan::expressions::{sum_return_type, Column as FusionColumn, Max, Min, Sum};
14+
use datafusion::physical_plan::expressions::{
15+
sum_return_type, Column as FusionColumn, Max, Min, Sum,
16+
};
1517
use datafusion::physical_plan::{udaf, AggregateExpr, PhysicalExpr};
1618
use itertools::Itertools;
1719

@@ -77,7 +79,12 @@ impl AggregateColumn {
7779
let res: Arc<dyn AggregateExpr> = match self.function {
7880
AggregateFunction::SUM => {
7981
let input_data_type = col.data_type(schema)?;
80-
Arc::new(Sum::new(col.clone(), col.name(), sum_return_type(&input_data_type)?, &input_data_type))
82+
Arc::new(Sum::new(
83+
col.clone(),
84+
col.name(),
85+
sum_return_type(&input_data_type)?,
86+
&input_data_type,
87+
))
8188
}
8289
AggregateFunction::MAX => {
8390
Arc::new(Max::new(col.clone(), col.name(), col.data_type(schema)?))

0 commit comments

Comments
 (0)