>>> df = session.create_dataframe([
... [1, "Excellent"],
... [1, "Excellent"],
... [1, "Great"],
... [1, "Mediocre"],
... [2, "Terrible"],
... [2, "Bad"],
... ], schema=["product_id", "review"])
>>> summary_df = df.select(ai_summarize_agg(col("review")))
>>> summary_df.count()
1
>>> summary_df = df.group_by("product_id").agg(ai_summarize_agg(col("review")))
>>> summary_df.count()
2