thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-11-21 15:12:02 +00:00
Code Issues Packages Projects Releases Wiki Activity

fixed

Browse Source
This commit is contained in:
lgbo-ustc 2024-11-14 14:39:14 +08:00
parent 25fbc79376
commit 43a57c4f56
1 changed files with 15 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

19
src/Processors/Transforms/WindowTransform.cpp
View File

@ -1546,7 +1546,10 @@ struct WindowFunctionRank final : public StatelessWindowFunction
RowNumber firstRequiredRowInFrame(const WindowTransform * transform) const override RowNumber firstRequiredRowInFrame(const WindowTransform * transform) const override
{ {
return transform->peer_group_start; if (transform->window_description.frame.begin_type == WindowFrame::BoundaryType::Unbounded
&& transform->window_description.frame.end_type == WindowFrame::BoundaryType::Current)
return transform->peer_group_start;
return transform->frame_start;
} }
}; };
@ -1569,7 +1572,10 @@ struct WindowFunctionDenseRank final : public StatelessWindowFunction
RowNumber firstRequiredRowInFrame(const WindowTransform * transform) const override RowNumber firstRequiredRowInFrame(const WindowTransform * transform) const override
{ {
return transform->peer_group_start; if (transform->window_description.frame.begin_type == WindowFrame::BoundaryType::Unbounded
&& transform->window_description.frame.end_type == WindowFrame::BoundaryType::Current)
return transform->peer_group_start;
return transform->frame_start;
} }
}; };
@ -2050,8 +2056,13 @@ struct WindowFunctionRowNumber final : public StatelessWindowFunction
RowNumber firstRequiredRowInFrame(const WindowTransform * transform) const override RowNumber firstRequiredRowInFrame(const WindowTransform * transform) const override
{ {
/// Current block is the only one required to be kept in memory. /// Current block is the only one required to be kept in memory.
auto [row, _] = transform->moveRowNumber(transform->current_row, -1); if (transform->window_description.frame.begin_type == WindowFrame::BoundaryType::Unbounded
return row; && transform->window_description.frame.end_type == WindowFrame::BoundaryType::Current)
{
auto [row, _] = transform->moveRowNumber(transform->current_row, -1);
return row;
}
return transform->frame_start;
} }
}; };