GeezerVison is showing github.com — feldera/python/felderize/felderize/spark_sql/simple_query.sql at main · feldera/feldera

Expand file tree

simple_query.sql

Copy path

More file actions

11 lines (10 loc) · 291 Bytes

Copy path

11 lines (10 loc) · 291 Bytes

Copy raw file

Download raw file

Open symbols panel

Edit and raw actions

-- Spark SQL

CREATE OR REPLACE TEMP VIEW revenue_by_region_month AS

SELECT

region,

date_trunc('MONTH', created_at) AS order_month,

COUNT(*) AS order_count,

SUM(amount) AS total_amount

FROM orders

WHERE status IN ('PAID', 'SHIPPED')

GROUP BY region, date_trunc('MONTH', created_at);