-
Notifications
You must be signed in to change notification settings - Fork 97
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
- Loading branch information
1 parent
81da847
commit 5e67a05
Showing
12 changed files
with
1,674 additions
and
0 deletions.
There are no files selected for viewing
241 changes: 241 additions & 0 deletions
241
...y/SqlQueryPlan/BigQuery/test_join_to_time_spine_metric_grouped_by_custom_grain__plan0.sql
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
@@ -0,0 +1,241 @@ | ||
-- Compute Metrics via Expressions | ||
SELECT | ||
subq_8.metric_time__martian_day | ||
, subq_8.bookings AS bookings_join_to_time_spine | ||
FROM ( | ||
-- Join to Time Spine Dataset | ||
SELECT | ||
subq_6.metric_time__martian_day AS metric_time__martian_day | ||
, subq_5.bookings AS bookings | ||
FROM ( | ||
-- Time Spine | ||
SELECT | ||
subq_7.martian_day AS metric_time__martian_day | ||
FROM ***************************.mf_time_spine subq_7 | ||
GROUP BY | ||
metric_time__martian_day | ||
) subq_6 | ||
LEFT OUTER JOIN ( | ||
-- Aggregate Measures | ||
SELECT | ||
subq_4.metric_time__martian_day | ||
, SUM(subq_4.bookings) AS bookings | ||
FROM ( | ||
-- Pass Only Elements: ['bookings', 'metric_time__martian_day'] | ||
SELECT | ||
subq_3.metric_time__martian_day | ||
, subq_3.bookings | ||
FROM ( | ||
-- Pass Only Elements: ['bookings', 'metric_time__day'] | ||
-- Join to Custom Granularity Dataset | ||
SELECT | ||
subq_1.metric_time__day AS metric_time__day | ||
, subq_1.bookings AS bookings | ||
, subq_2.martian_day AS metric_time__martian_day | ||
FROM ( | ||
-- Metric Time Dimension 'ds' | ||
SELECT | ||
subq_0.ds__day | ||
, subq_0.ds__week | ||
, subq_0.ds__month | ||
, subq_0.ds__quarter | ||
, subq_0.ds__year | ||
, subq_0.ds__extract_year | ||
, subq_0.ds__extract_quarter | ||
, subq_0.ds__extract_month | ||
, subq_0.ds__extract_day | ||
, subq_0.ds__extract_dow | ||
, subq_0.ds__extract_doy | ||
, subq_0.ds_partitioned__day | ||
, subq_0.ds_partitioned__week | ||
, subq_0.ds_partitioned__month | ||
, subq_0.ds_partitioned__quarter | ||
, subq_0.ds_partitioned__year | ||
, subq_0.ds_partitioned__extract_year | ||
, subq_0.ds_partitioned__extract_quarter | ||
, subq_0.ds_partitioned__extract_month | ||
, subq_0.ds_partitioned__extract_day | ||
, subq_0.ds_partitioned__extract_dow | ||
, subq_0.ds_partitioned__extract_doy | ||
, subq_0.paid_at__day | ||
, subq_0.paid_at__week | ||
, subq_0.paid_at__month | ||
, subq_0.paid_at__quarter | ||
, subq_0.paid_at__year | ||
, subq_0.paid_at__extract_year | ||
, subq_0.paid_at__extract_quarter | ||
, subq_0.paid_at__extract_month | ||
, subq_0.paid_at__extract_day | ||
, subq_0.paid_at__extract_dow | ||
, subq_0.paid_at__extract_doy | ||
, subq_0.booking__ds__day | ||
, subq_0.booking__ds__week | ||
, subq_0.booking__ds__month | ||
, subq_0.booking__ds__quarter | ||
, subq_0.booking__ds__year | ||
, subq_0.booking__ds__extract_year | ||
, subq_0.booking__ds__extract_quarter | ||
, subq_0.booking__ds__extract_month | ||
, subq_0.booking__ds__extract_day | ||
, subq_0.booking__ds__extract_dow | ||
, subq_0.booking__ds__extract_doy | ||
, subq_0.booking__ds_partitioned__day | ||
, subq_0.booking__ds_partitioned__week | ||
, subq_0.booking__ds_partitioned__month | ||
, subq_0.booking__ds_partitioned__quarter | ||
, subq_0.booking__ds_partitioned__year | ||
, subq_0.booking__ds_partitioned__extract_year | ||
, subq_0.booking__ds_partitioned__extract_quarter | ||
, subq_0.booking__ds_partitioned__extract_month | ||
, subq_0.booking__ds_partitioned__extract_day | ||
, subq_0.booking__ds_partitioned__extract_dow | ||
, subq_0.booking__ds_partitioned__extract_doy | ||
, subq_0.booking__paid_at__day | ||
, subq_0.booking__paid_at__week | ||
, subq_0.booking__paid_at__month | ||
, subq_0.booking__paid_at__quarter | ||
, subq_0.booking__paid_at__year | ||
, subq_0.booking__paid_at__extract_year | ||
, subq_0.booking__paid_at__extract_quarter | ||
, subq_0.booking__paid_at__extract_month | ||
, subq_0.booking__paid_at__extract_day | ||
, subq_0.booking__paid_at__extract_dow | ||
, subq_0.booking__paid_at__extract_doy | ||
, subq_0.ds__day AS metric_time__day | ||
, subq_0.ds__week AS metric_time__week | ||
, subq_0.ds__month AS metric_time__month | ||
, subq_0.ds__quarter AS metric_time__quarter | ||
, subq_0.ds__year AS metric_time__year | ||
, subq_0.ds__extract_year AS metric_time__extract_year | ||
, subq_0.ds__extract_quarter AS metric_time__extract_quarter | ||
, subq_0.ds__extract_month AS metric_time__extract_month | ||
, subq_0.ds__extract_day AS metric_time__extract_day | ||
, subq_0.ds__extract_dow AS metric_time__extract_dow | ||
, subq_0.ds__extract_doy AS metric_time__extract_doy | ||
, subq_0.listing | ||
, subq_0.guest | ||
, subq_0.host | ||
, subq_0.booking__listing | ||
, subq_0.booking__guest | ||
, subq_0.booking__host | ||
, subq_0.is_instant | ||
, subq_0.booking__is_instant | ||
, subq_0.bookings | ||
, subq_0.instant_bookings | ||
, subq_0.booking_value | ||
, subq_0.max_booking_value | ||
, subq_0.min_booking_value | ||
, subq_0.bookers | ||
, subq_0.average_booking_value | ||
, subq_0.referred_bookings | ||
, subq_0.median_booking_value | ||
, subq_0.booking_value_p99 | ||
, subq_0.discrete_booking_value_p99 | ||
, subq_0.approximate_continuous_booking_value_p99 | ||
, subq_0.approximate_discrete_booking_value_p99 | ||
FROM ( | ||
-- Read Elements From Semantic Model 'bookings_source' | ||
SELECT | ||
1 AS bookings | ||
, CASE WHEN is_instant THEN 1 ELSE 0 END AS instant_bookings | ||
, bookings_source_src_28000.booking_value | ||
, bookings_source_src_28000.booking_value AS max_booking_value | ||
, bookings_source_src_28000.booking_value AS min_booking_value | ||
, bookings_source_src_28000.guest_id AS bookers | ||
, bookings_source_src_28000.booking_value AS average_booking_value | ||
, bookings_source_src_28000.booking_value AS booking_payments | ||
, CASE WHEN referrer_id IS NOT NULL THEN 1 ELSE 0 END AS referred_bookings | ||
, bookings_source_src_28000.booking_value AS median_booking_value | ||
, bookings_source_src_28000.booking_value AS booking_value_p99 | ||
, bookings_source_src_28000.booking_value AS discrete_booking_value_p99 | ||
, bookings_source_src_28000.booking_value AS approximate_continuous_booking_value_p99 | ||
, bookings_source_src_28000.booking_value AS approximate_discrete_booking_value_p99 | ||
, bookings_source_src_28000.is_instant | ||
, DATETIME_TRUNC(bookings_source_src_28000.ds, day) AS ds__day | ||
, DATETIME_TRUNC(bookings_source_src_28000.ds, isoweek) AS ds__week | ||
, DATETIME_TRUNC(bookings_source_src_28000.ds, month) AS ds__month | ||
, DATETIME_TRUNC(bookings_source_src_28000.ds, quarter) AS ds__quarter | ||
, DATETIME_TRUNC(bookings_source_src_28000.ds, year) AS ds__year | ||
, EXTRACT(year FROM bookings_source_src_28000.ds) AS ds__extract_year | ||
, EXTRACT(quarter FROM bookings_source_src_28000.ds) AS ds__extract_quarter | ||
, EXTRACT(month FROM bookings_source_src_28000.ds) AS ds__extract_month | ||
, EXTRACT(day FROM bookings_source_src_28000.ds) AS ds__extract_day | ||
, IF(EXTRACT(dayofweek FROM bookings_source_src_28000.ds) = 1, 7, EXTRACT(dayofweek FROM bookings_source_src_28000.ds) - 1) AS ds__extract_dow | ||
, EXTRACT(dayofyear FROM bookings_source_src_28000.ds) AS ds__extract_doy | ||
, DATETIME_TRUNC(bookings_source_src_28000.ds_partitioned, day) AS ds_partitioned__day | ||
, DATETIME_TRUNC(bookings_source_src_28000.ds_partitioned, isoweek) AS ds_partitioned__week | ||
, DATETIME_TRUNC(bookings_source_src_28000.ds_partitioned, month) AS ds_partitioned__month | ||
, DATETIME_TRUNC(bookings_source_src_28000.ds_partitioned, quarter) AS ds_partitioned__quarter | ||
, DATETIME_TRUNC(bookings_source_src_28000.ds_partitioned, year) AS ds_partitioned__year | ||
, EXTRACT(year FROM bookings_source_src_28000.ds_partitioned) AS ds_partitioned__extract_year | ||
, EXTRACT(quarter FROM bookings_source_src_28000.ds_partitioned) AS ds_partitioned__extract_quarter | ||
, EXTRACT(month FROM bookings_source_src_28000.ds_partitioned) AS ds_partitioned__extract_month | ||
, EXTRACT(day FROM bookings_source_src_28000.ds_partitioned) AS ds_partitioned__extract_day | ||
, IF(EXTRACT(dayofweek FROM bookings_source_src_28000.ds_partitioned) = 1, 7, EXTRACT(dayofweek FROM bookings_source_src_28000.ds_partitioned) - 1) AS ds_partitioned__extract_dow | ||
, EXTRACT(dayofyear FROM bookings_source_src_28000.ds_partitioned) AS ds_partitioned__extract_doy | ||
, DATETIME_TRUNC(bookings_source_src_28000.paid_at, day) AS paid_at__day | ||
, DATETIME_TRUNC(bookings_source_src_28000.paid_at, isoweek) AS paid_at__week | ||
, DATETIME_TRUNC(bookings_source_src_28000.paid_at, month) AS paid_at__month | ||
, DATETIME_TRUNC(bookings_source_src_28000.paid_at, quarter) AS paid_at__quarter | ||
, DATETIME_TRUNC(bookings_source_src_28000.paid_at, year) AS paid_at__year | ||
, EXTRACT(year FROM bookings_source_src_28000.paid_at) AS paid_at__extract_year | ||
, EXTRACT(quarter FROM bookings_source_src_28000.paid_at) AS paid_at__extract_quarter | ||
, EXTRACT(month FROM bookings_source_src_28000.paid_at) AS paid_at__extract_month | ||
, EXTRACT(day FROM bookings_source_src_28000.paid_at) AS paid_at__extract_day | ||
, IF(EXTRACT(dayofweek FROM bookings_source_src_28000.paid_at) = 1, 7, EXTRACT(dayofweek FROM bookings_source_src_28000.paid_at) - 1) AS paid_at__extract_dow | ||
, EXTRACT(dayofyear FROM bookings_source_src_28000.paid_at) AS paid_at__extract_doy | ||
, bookings_source_src_28000.is_instant AS booking__is_instant | ||
, DATETIME_TRUNC(bookings_source_src_28000.ds, day) AS booking__ds__day | ||
, DATETIME_TRUNC(bookings_source_src_28000.ds, isoweek) AS booking__ds__week | ||
, DATETIME_TRUNC(bookings_source_src_28000.ds, month) AS booking__ds__month | ||
, DATETIME_TRUNC(bookings_source_src_28000.ds, quarter) AS booking__ds__quarter | ||
, DATETIME_TRUNC(bookings_source_src_28000.ds, year) AS booking__ds__year | ||
, EXTRACT(year FROM bookings_source_src_28000.ds) AS booking__ds__extract_year | ||
, EXTRACT(quarter FROM bookings_source_src_28000.ds) AS booking__ds__extract_quarter | ||
, EXTRACT(month FROM bookings_source_src_28000.ds) AS booking__ds__extract_month | ||
, EXTRACT(day FROM bookings_source_src_28000.ds) AS booking__ds__extract_day | ||
, IF(EXTRACT(dayofweek FROM bookings_source_src_28000.ds) = 1, 7, EXTRACT(dayofweek FROM bookings_source_src_28000.ds) - 1) AS booking__ds__extract_dow | ||
, EXTRACT(dayofyear FROM bookings_source_src_28000.ds) AS booking__ds__extract_doy | ||
, DATETIME_TRUNC(bookings_source_src_28000.ds_partitioned, day) AS booking__ds_partitioned__day | ||
, DATETIME_TRUNC(bookings_source_src_28000.ds_partitioned, isoweek) AS booking__ds_partitioned__week | ||
, DATETIME_TRUNC(bookings_source_src_28000.ds_partitioned, month) AS booking__ds_partitioned__month | ||
, DATETIME_TRUNC(bookings_source_src_28000.ds_partitioned, quarter) AS booking__ds_partitioned__quarter | ||
, DATETIME_TRUNC(bookings_source_src_28000.ds_partitioned, year) AS booking__ds_partitioned__year | ||
, EXTRACT(year FROM bookings_source_src_28000.ds_partitioned) AS booking__ds_partitioned__extract_year | ||
, EXTRACT(quarter FROM bookings_source_src_28000.ds_partitioned) AS booking__ds_partitioned__extract_quarter | ||
, EXTRACT(month FROM bookings_source_src_28000.ds_partitioned) AS booking__ds_partitioned__extract_month | ||
, EXTRACT(day FROM bookings_source_src_28000.ds_partitioned) AS booking__ds_partitioned__extract_day | ||
, IF(EXTRACT(dayofweek FROM bookings_source_src_28000.ds_partitioned) = 1, 7, EXTRACT(dayofweek FROM bookings_source_src_28000.ds_partitioned) - 1) AS booking__ds_partitioned__extract_dow | ||
, EXTRACT(dayofyear FROM bookings_source_src_28000.ds_partitioned) AS booking__ds_partitioned__extract_doy | ||
, DATETIME_TRUNC(bookings_source_src_28000.paid_at, day) AS booking__paid_at__day | ||
, DATETIME_TRUNC(bookings_source_src_28000.paid_at, isoweek) AS booking__paid_at__week | ||
, DATETIME_TRUNC(bookings_source_src_28000.paid_at, month) AS booking__paid_at__month | ||
, DATETIME_TRUNC(bookings_source_src_28000.paid_at, quarter) AS booking__paid_at__quarter | ||
, DATETIME_TRUNC(bookings_source_src_28000.paid_at, year) AS booking__paid_at__year | ||
, EXTRACT(year FROM bookings_source_src_28000.paid_at) AS booking__paid_at__extract_year | ||
, EXTRACT(quarter FROM bookings_source_src_28000.paid_at) AS booking__paid_at__extract_quarter | ||
, EXTRACT(month FROM bookings_source_src_28000.paid_at) AS booking__paid_at__extract_month | ||
, EXTRACT(day FROM bookings_source_src_28000.paid_at) AS booking__paid_at__extract_day | ||
, IF(EXTRACT(dayofweek FROM bookings_source_src_28000.paid_at) = 1, 7, EXTRACT(dayofweek FROM bookings_source_src_28000.paid_at) - 1) AS booking__paid_at__extract_dow | ||
, EXTRACT(dayofyear FROM bookings_source_src_28000.paid_at) AS booking__paid_at__extract_doy | ||
, bookings_source_src_28000.listing_id AS listing | ||
, bookings_source_src_28000.guest_id AS guest | ||
, bookings_source_src_28000.host_id AS host | ||
, bookings_source_src_28000.listing_id AS booking__listing | ||
, bookings_source_src_28000.guest_id AS booking__guest | ||
, bookings_source_src_28000.host_id AS booking__host | ||
FROM ***************************.fct_bookings bookings_source_src_28000 | ||
) subq_0 | ||
) subq_1 | ||
LEFT OUTER JOIN | ||
***************************.mf_time_spine subq_2 | ||
ON | ||
subq_1.metric_time__day = subq_2.ds | ||
) subq_3 | ||
) subq_4 | ||
GROUP BY | ||
metric_time__martian_day | ||
) subq_5 | ||
ON | ||
subq_6.metric_time__martian_day = subq_5.metric_time__martian_day | ||
) subq_8 |
38 changes: 38 additions & 0 deletions
38
...Plan/BigQuery/test_join_to_time_spine_metric_grouped_by_custom_grain__plan0_optimized.sql
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
@@ -0,0 +1,38 @@ | ||
-- Join to Time Spine Dataset | ||
-- Compute Metrics via Expressions | ||
SELECT | ||
subq_15.metric_time__martian_day AS metric_time__martian_day | ||
, subq_14.bookings AS bookings_join_to_time_spine | ||
FROM ( | ||
-- Time Spine | ||
SELECT | ||
martian_day AS metric_time__martian_day | ||
FROM ***************************.mf_time_spine subq_16 | ||
GROUP BY | ||
metric_time__martian_day | ||
) subq_15 | ||
LEFT OUTER JOIN ( | ||
-- Pass Only Elements: ['bookings', 'metric_time__day'] | ||
-- Join to Custom Granularity Dataset | ||
-- Pass Only Elements: ['bookings', 'metric_time__martian_day'] | ||
-- Aggregate Measures | ||
SELECT | ||
subq_11.martian_day AS metric_time__martian_day | ||
, SUM(subq_10.bookings) AS bookings | ||
FROM ( | ||
-- Read Elements From Semantic Model 'bookings_source' | ||
-- Metric Time Dimension 'ds' | ||
SELECT | ||
DATETIME_TRUNC(ds, day) AS metric_time__day | ||
, 1 AS bookings | ||
FROM ***************************.fct_bookings bookings_source_src_28000 | ||
) subq_10 | ||
LEFT OUTER JOIN | ||
***************************.mf_time_spine subq_11 | ||
ON | ||
subq_10.metric_time__day = subq_11.ds | ||
GROUP BY | ||
metric_time__martian_day | ||
) subq_14 | ||
ON | ||
subq_15.metric_time__martian_day = subq_14.metric_time__martian_day |
Oops, something went wrong.