Robert Howell
04/29/2025, 7:09 PMDataFrame.pipe for composing operators, anyone can review. This came from Dom on PR 4112.
PR for .pipe ---> https://github.com/Eventual-Inc/Daft/pull/4267
Example
import daft
df = daft.from_pydict({"x": [1, 2, 3]})
def double(df, column: str):
return df.select((df[column] * df[column]).alias(column))
df.pipe(double, "x").show()
╭───────╮
│ x │
│ --- │
│ Int64 │
╞═══════╡
│ 1 │
├╌╌╌╌╌╌╌┤
│ 4 │
├╌╌╌╌╌╌╌┤
│ 9 │
╰───────╯
(Showing first 3 of 3 rows)