Skip to content

Commit d10ec22

Browse files
committed
fix fmt
1 parent 93cee55 commit d10ec22

File tree

1 file changed

+6
-4
lines changed
  • datafusion/proto/src/physical_plan

1 file changed

+6
-4
lines changed

datafusion/proto/src/physical_plan/mod.rs

Lines changed: 6 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -932,9 +932,9 @@ impl protobuf::PhysicalPlanNode {
932932
let agg_mode: AggregateMode = match mode {
933933
protobuf::AggregateMode::Partial => AggregateMode::Partial,
934934
protobuf::AggregateMode::Final => AggregateMode::Final,
935-
protobuf::AggregateMode::FinalPartitioned => AggregateMode::FinalPartitioned(
936-
HashPartitionMode::HashPartitioned,
937-
),
935+
protobuf::AggregateMode::FinalPartitioned => {
936+
AggregateMode::FinalPartitioned(HashPartitionMode::HashPartitioned)
937+
}
938938
protobuf::AggregateMode::Single => AggregateMode::Single,
939939
protobuf::AggregateMode::SinglePartitioned => {
940940
AggregateMode::SinglePartitioned
@@ -2149,7 +2149,9 @@ impl protobuf::PhysicalPlanNode {
21492149
let agg_mode = match exec.mode() {
21502150
AggregateMode::Partial => protobuf::AggregateMode::Partial,
21512151
AggregateMode::Final => protobuf::AggregateMode::Final,
2152-
AggregateMode::FinalPartitioned(_) => protobuf::AggregateMode::FinalPartitioned,
2152+
AggregateMode::FinalPartitioned(_) => {
2153+
protobuf::AggregateMode::FinalPartitioned
2154+
}
21532155
AggregateMode::Single => protobuf::AggregateMode::Single,
21542156
AggregateMode::SinglePartitioned => {
21552157
protobuf::AggregateMode::SinglePartitioned

0 commit comments

Comments
 (0)