Skip to content

Commit 506319e

Browse files
authored
chore: Add test for implode + over (#22437)
1 parent 3e64135 commit 506319e

File tree

1 file changed

+26
-0
lines changed

1 file changed

+26
-0
lines changed
Lines changed: 26 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,26 @@
1+
import polars as pl
2+
from polars.testing import assert_series_equal
3+
4+
5+
def test_implode_explode_over_22188() -> None:
6+
df = pl.DataFrame(
7+
{
8+
"x": [1, 2, 3, 1, 2, 3, 1, 2, 3],
9+
"y": [2, 2, 2, 3, 3, 3, 4, 4, 4],
10+
}
11+
)
12+
result = df.select(
13+
(pl.col.x * (pl.lit(pl.Series([1, 1, 1])).implode().explode())).over(pl.col.y),
14+
)
15+
16+
assert_series_equal(result.to_series(), df.get_column("x"))
17+
18+
19+
def test_implode_in_over_22188() -> None:
20+
df = pl.DataFrame(
21+
{
22+
"x": [[1], [2], [3]],
23+
"y": [2, 3, 4],
24+
}
25+
).select(pl.col.x.list.set_union(pl.lit(pl.Series([1])).implode()).over(pl.col.y))
26+
assert_series_equal(df.to_series(), pl.Series("x", [[1], [2, 1], [3, 1]]))

0 commit comments

Comments
 (0)