Data Warehouse

SELECT * FROM s3('s3://northwind-lake/raw_llm_request_logs/dt=2026-07-*/*.parquet') WHERE JSONExtractString(payload, 'error') != ''

SELECT type, count() FROM raw_stripe_events WHERE dt BETWEEN '2026-01-01' AND '2026-07-26' GROUP BY type

SELECT distinct_id, count() FROM raw_posthog_export WHERE event = '$pageview' AND dt >= '2026-06-01' GROUP BY distinct_id ORDER BY 2 DESC LIMIT 500

SELECT toStartOfHour(invoked_at) AS h, quantile(0.95)(latency_ms) AS p95 FROM fact_ai_invocations WHERE model_name LIKE 'claude%' GROUP BY h ORDER BY h

SELECT cohort_month, countIf(week_index = 4) / count() AS w4_retention FROM fact_sessions JOIN dim_users USING (user_id) GROUP BY cohort_month

SELECT product_id, model_name, sum(cost_usd) AS spend FROM fact_ai_invocations WHERE invoked_at >= now() - INTERVAL 90 DAY GROUP BY product_id, model_name ORDER BY spend DESC

SELECT feature, product_id, count() AS uses FROM fact_feature_events WHERE occurred_at >= now() - INTERVAL 180 DAY GROUP BY feature, product_id HAVING uses > 1000

SELECT path, uniqExact(user_id) AS visitors FROM fact_page_views WHERE viewed_at >= today() - 30 GROUP BY path ORDER BY visitors DESC LIMIT 100