sql 斯卡拉火花-SQL totalrevenuedaily.sql

Posted 2021-05-13

SET spark.sql.shuffle.partitions; //default 200
SET spark.sql.shuffle.partitions = 2;
SELECT o.order_date, sum(oi.order_item_subtotal) daily_revenue
      FROM orders o JOIN order_items oi
      ON o.order_id = oi.order_item_order_id
      WHERE o.order_status = 'COMPLETE'
      GROUP BY o.order_date
      ORDER BY o.order_date;