Flowfile

On the canvas

1. Read — load supermarket_sales.csv
2. Drop Duplicates — remove repeated invoice rows
3. Filter — keep bulk orders: [quantity] > 7
4. Group By — per city, the sum and median of gross income

In Python

import flowfile as ff

df = ff.read_csv("data/templates/supermarket_sales.csv")

result = (
    df.unique()
    .filter(ff.col("quantity") > 7)
    .group_by("city")
    .agg(
        ff.col("gross_income").sum().alias("total_income"),
        ff.col("gross_income").median().alias("median_income"),
    )
)

print(result.collect())