Small PR to add `DataFrame.pipe` for composing ope...
# daft-dev
r
Small PR to add
DataFrame.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
Copy code
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)
🔥 1