Skip to content

Commit ed790d6

Browse files
author
silezhou
committed
style: cargo fmt
1 parent 90ef03d commit ed790d6

File tree

4 files changed

+5
-14
lines changed

4 files changed

+5
-14
lines changed

datafusion/physical-plan/src/coalesce_batches.rs

Lines changed: 0 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -129,13 +129,6 @@ impl DisplayAs for CoalesceBatchesExec {
129129
};
130130
Ok(())
131131
}
132-
DisplayFormatType::TreeRender => {
133-
writeln!(f, "target_batch_size={}", self.target_batch_size)?;
134-
if let Some(fetch) = self.fetch {
135-
write!(f, "limit={fetch}")?;
136-
};
137-
Ok(())
138-
}
139132
}
140133
}
141134
}

datafusion/sql/src/planner.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -575,7 +575,7 @@ impl<'a, S: ContextProvider> SqlToRel<'a, S> {
575575
}
576576
}
577577
}
578-
SQLDataType::UnsignedBigInt(_) | SQLDataType::UnsignedInt8(_) => Ok(DataType::UInt64),
578+
SQLDataType::BigIntUnsigned(_) | SQLDataType::Int8Unsigned(_) => Ok(DataType::UInt64),
579579
SQLDataType::Float(_) => Ok(DataType::Float32),
580580
SQLDataType::Real | SQLDataType::Float4 => Ok(DataType::Float32),
581581
SQLDataType::Double(ExactNumberInfo::None) | SQLDataType::DoublePrecision | SQLDataType::Float8 => Ok(DataType::Float64),

datafusion/sql/src/select.rs

Lines changed: 0 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -29,7 +29,6 @@ use crate::utils::{
2929
use datafusion_common::error::DataFusionErrorBuilder;
3030
use datafusion_common::tree_node::{TreeNode, TreeNodeRecursion};
3131
use datafusion_common::{not_impl_err, plan_err, Column, Result};
32-
use datafusion_common::{not_impl_err, plan_err, Column, Result};
3332
use datafusion_common::{RecursionUnnestOption, UnnestOptions};
3433
use datafusion_expr::expr::{Alias, PlannedReplaceSelectItem, WildcardOptions};
3534
use datafusion_expr::expr_rewriter::{
@@ -38,8 +37,6 @@ use datafusion_expr::expr_rewriter::{
3837
use datafusion_expr::utils::{
3938
expand_qualified_wildcard, expand_wildcard, expr_as_column_expr, expr_to_columns,
4039
find_aggregate_exprs, find_window_exprs,
41-
expand_qualified_wildcard, expand_wildcard, expr_as_column_expr, expr_to_columns,
42-
find_aggregate_exprs, find_window_exprs,
4340
};
4441
use datafusion_expr::{
4542
Aggregate, Expr, Filter, GroupingSet, LogicalPlan, LogicalPlanBuilder,

datafusion/sql/tests/cases/plan_to_sql.rs

Lines changed: 4 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -21,9 +21,10 @@ use datafusion_expr::test::function_stub::{
2121
count_udaf, max_udaf, min_udaf, sum, sum_udaf,
2222
};
2323
use datafusion_expr::{
24-
cast, col, lit, table_scan, wildcard, EmptyRelation, Expr, Extension, LogicalPlan,
25-
cast, col, lit, table_scan, wildcard, EmptyRelation, Expr, Extension, LogicalPlan,
26-
LogicalPlanBuilder, Union, UserDefinedLogicalNode, UserDefinedLogicalNodeCore,
24+
cast, cast, col, col, lit, lit, table_scan, table_scan, wildcard, wildcard,
25+
EmptyRelation, EmptyRelation, Expr, Expr, Extension, Extension, LogicalPlan,
26+
LogicalPlan, LogicalPlanBuilder, Union, UserDefinedLogicalNode,
27+
UserDefinedLogicalNodeCore,
2728
};
2829
use datafusion_functions::unicode;
2930
use datafusion_functions_aggregate::grouping::grouping_udaf;

0 commit comments

Comments
 (0)