Skip to content

Commit

Permalink
formatting
Browse files Browse the repository at this point in the history
  • Loading branch information
huaxingao committed Sep 23, 2024
1 parent 78f18f6 commit 94c7739
Showing 1 changed file with 5 additions and 3 deletions.
8 changes: 5 additions & 3 deletions native/core/src/execution/datafusion/planner.rs
Original file line number Diff line number Diff line change
Expand Up @@ -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."
Expand All @@ -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."
)))
}
},
};

Expand Down Expand Up @@ -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."
)))
}
},
};

Expand Down

0 comments on commit 94c7739

Please sign in to comment.