From 94c7739417459cc8fc1b20f0db5acb39a9e8a86e Mon Sep 17 00:00:00 2001 From: huaxingao Date: Mon, 23 Sep 2024 12:01:04 -0700 Subject: [PATCH] formatting --- native/core/src/execution/datafusion/planner.rs | 8 +++++--- 1 file changed, 5 insertions(+), 3 deletions(-) diff --git a/native/core/src/execution/datafusion/planner.rs b/native/core/src/execution/datafusion/planner.rs index 64adf22584..d38eca28ff 100644 --- a/native/core/src/execution/datafusion/planner.rs +++ b/native/core/src/execution/datafusion/planner.rs @@ -1713,7 +1713,7 @@ impl PhysicalPlanner { )), WindowFrameUnits::Range => { WindowFrameBound::Preceding(ScalarValue::Int64(Some(offset_value))) - }, + } WindowFrameUnits::Groups => { return Err(ExecutionError::GeneralError(format!( "WindowFrameUnits::Groups is not supported." @@ -1726,10 +1726,11 @@ impl PhysicalPlanner { None => match units { WindowFrameUnits::Rows => WindowFrameBound::Preceding(ScalarValue::UInt64(None)), WindowFrameUnits::Range => WindowFrameBound::Preceding(ScalarValue::Int64(None)), - WindowFrameUnits::Groups => + WindowFrameUnits::Groups => { return Err(ExecutionError::GeneralError(format!( "WindowFrameUnits::Groups is not supported." ))) + } }, }; @@ -1770,10 +1771,11 @@ impl PhysicalPlanner { None => match units { WindowFrameUnits::Rows => WindowFrameBound::Following(ScalarValue::UInt64(None)), WindowFrameUnits::Range => WindowFrameBound::Following(ScalarValue::Int64(None)), - WindowFrameUnits::Groups => + WindowFrameUnits::Groups => { return Err(ExecutionError::GeneralError(format!( "WindowFrameUnits::Groups is not supported." ))) + } }, };