Skip to content

Commit 710d916

Browse files
committed
fix size_hint
1 parent 8d8163b commit 710d916

File tree

2 files changed

+2
-1
lines changed

2 files changed

+2
-1
lines changed

crates/polars-expr/src/expressions/apply.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -137,7 +137,7 @@ impl ApplyExpr {
137137

138138
// In case of overlapping (rolling) groups, we build groups in a lazy manner to avoid
139139
// memory explosion.
140-
// kdn TODO: TBD - do we want to follow this path for *all* Slice
140+
// kdn TODO: TBD - do we want to follow this path for *all* Slice groupstype?
141141
if matches!(ac.agg_state(), AggState::NotAggregated(_))
142142
&& let GroupsType::Slice { rolling: true, .. } = ac.groups.as_ref().as_ref()
143143
{

crates/polars-expr/src/expressions/group_iter.rs

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -264,6 +264,7 @@ impl<'a, I: Iterator<Item = GroupsIndicator<'a>>> Iterator for NotAggLazyIter<'a
264264

265265
fn next(&mut self) -> Option<Self::Item> {
266266
if let Some(g) = self.iter.next() {
267+
self.groups_idx += 1;
267268
match g {
268269
GroupsIndicator::Idx(_) => todo!(), //kdn TODO
269270
GroupsIndicator::Slice(s) => {

0 commit comments

Comments
 (0)