✅Выберите правильную запись/правильные записи sql-запроса на Spark.
Запрос:
SELECT country, COUNT(customer_id)
FROM shop.customers
WHERE date = '2024-02-08'
GROUP BY country
HAVING COUNT(customer) > 5;
Варианты на Spark:
1) df = (
spark.table("shop.customers")
.select("country", "count(customer_id)")
.where("date = '2024-02-08'")
.groupBy("country")
.having("count(customer_id) > 5")
)
2) df = (
spark.table("shop.customers")
.where("date = '2024-02-08'")
.groupBy("country")
.agg(F.count("customer_id").alias("cnt"))
.where("cnt > 5")
)
3) df = (
spark.table("shop.customers")
.where("date = '2024-02-08'")
.select("country")
.count("customer_id")
.groupBy("country")
.having("count(customer_id) > 5")
)
4) df = (
spark.table("shop.customers")
.filter(F.col("date") == '2024-02-08')
.groupBy("country")
.agg(F.count("customer_id"))
.where("count(customer_id)> 5")
)
Голосовалка ниже👇