-
Notifications
You must be signed in to change notification settings - Fork 99
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
a3f59b0
commit a736cee
Showing
24 changed files
with
6,996 additions
and
0 deletions.
There are no files selected for viewing
617 changes: 617 additions & 0 deletions
617
...y.py/SqlPlan/BigQuery/test_multiple_time_spines_in_query_for_cumulative_metric__plan0.sql
Large diffs are not rendered by default.
Oops, something went wrong.
35 changes: 35 additions & 0 deletions
35
...an/BigQuery/test_multiple_time_spines_in_query_for_cumulative_metric__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,35 @@ | ||
test_name: test_multiple_time_spines_in_query_for_cumulative_metric | ||
test_filename: test_custom_granularity.py | ||
sql_engine: BigQuery | ||
--- | ||
-- Join Self Over Time Range | ||
-- Join to Custom Granularity Dataset | ||
-- Pass Only Elements: ['archived_users', 'metric_time__martian_day', 'metric_time__hour'] | ||
-- Aggregate Measures | ||
-- Compute Metrics via Expressions | ||
SELECT | ||
subq_12.martian_day AS metric_time__martian_day | ||
, subq_11.ts AS metric_time__hour | ||
, SUM(subq_9.archived_users) AS subdaily_cumulative_window_metric | ||
FROM ***************************.mf_time_spine_hour subq_11 | ||
INNER JOIN ( | ||
-- Read Elements From Semantic Model 'users_ds_source' | ||
-- Metric Time Dimension 'archived_at' | ||
SELECT | ||
DATETIME_TRUNC(archived_at, hour) AS metric_time__hour | ||
, 1 AS archived_users | ||
FROM ***************************.dim_users users_ds_source_src_28000 | ||
) subq_9 | ||
ON | ||
( | ||
subq_9.metric_time__hour <= subq_11.ts | ||
) AND ( | ||
subq_9.metric_time__hour > DATE_SUB(CAST(subq_11.ts AS DATETIME), INTERVAL 3 hour) | ||
) | ||
LEFT OUTER JOIN | ||
***************************.mf_time_spine subq_12 | ||
ON | ||
DATETIME_TRUNC(subq_11.ts, day) = subq_12.ds | ||
GROUP BY | ||
metric_time__martian_day | ||
, metric_time__hour |
464 changes: 464 additions & 0 deletions
464
...Plan/BigQuery/test_multiple_time_spines_in_query_for_join_to_time_spine_metric__plan0.sql
Large diffs are not rendered by default.
Oops, something went wrong.
50 changes: 50 additions & 0 deletions
50
...ery/test_multiple_time_spines_in_query_for_join_to_time_spine_metric__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,50 @@ | ||
test_name: test_multiple_time_spines_in_query_for_join_to_time_spine_metric | ||
test_filename: test_custom_granularity.py | ||
sql_engine: BigQuery | ||
--- | ||
-- Join to Time Spine Dataset | ||
-- Compute Metrics via Expressions | ||
SELECT | ||
subq_18.metric_time__martian_day AS metric_time__martian_day | ||
, subq_18.metric_time__hour AS metric_time__hour | ||
, subq_14.archived_users AS subdaily_join_to_time_spine_metric | ||
FROM ( | ||
-- Change Column Aliases | ||
-- Join to Custom Granularity Dataset | ||
-- Pass Only Elements: ['metric_time__martian_day', 'metric_time__hour'] | ||
SELECT | ||
subq_16.martian_day AS metric_time__martian_day | ||
, time_spine_src_28005.ts AS metric_time__hour | ||
FROM ***************************.mf_time_spine_hour time_spine_src_28005 | ||
LEFT OUTER JOIN | ||
***************************.mf_time_spine subq_16 | ||
ON | ||
DATETIME_TRUNC(time_spine_src_28005.ts, day) = subq_16.ds | ||
) subq_18 | ||
LEFT OUTER JOIN ( | ||
-- Metric Time Dimension 'archived_at' | ||
-- Join to Custom Granularity Dataset | ||
-- Pass Only Elements: ['archived_users', 'metric_time__martian_day', 'metric_time__hour'] | ||
-- Aggregate Measures | ||
SELECT | ||
subq_11.martian_day AS metric_time__martian_day | ||
, subq_10.archived_at__hour AS metric_time__hour | ||
, SUM(subq_10.archived_users) AS archived_users | ||
FROM ( | ||
-- Read Elements From Semantic Model 'users_ds_source' | ||
SELECT | ||
1 AS archived_users | ||
, DATETIME_TRUNC(archived_at, hour) AS archived_at__hour | ||
, DATETIME_TRUNC(archived_at, day) AS archived_at__day | ||
FROM ***************************.dim_users users_ds_source_src_28000 | ||
) subq_10 | ||
LEFT OUTER JOIN | ||
***************************.mf_time_spine subq_11 | ||
ON | ||
subq_10.archived_at__day = subq_11.ds | ||
GROUP BY | ||
metric_time__martian_day | ||
, metric_time__hour | ||
) subq_14 | ||
ON | ||
subq_18.metric_time__hour = subq_14.metric_time__hour |
617 changes: 617 additions & 0 deletions
617
...py/SqlPlan/Databricks/test_multiple_time_spines_in_query_for_cumulative_metric__plan0.sql
Large diffs are not rendered by default.
Oops, something went wrong.
35 changes: 35 additions & 0 deletions
35
.../Databricks/test_multiple_time_spines_in_query_for_cumulative_metric__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,35 @@ | ||
test_name: test_multiple_time_spines_in_query_for_cumulative_metric | ||
test_filename: test_custom_granularity.py | ||
sql_engine: Databricks | ||
--- | ||
-- Join Self Over Time Range | ||
-- Join to Custom Granularity Dataset | ||
-- Pass Only Elements: ['archived_users', 'metric_time__martian_day', 'metric_time__hour'] | ||
-- Aggregate Measures | ||
-- Compute Metrics via Expressions | ||
SELECT | ||
subq_12.martian_day AS metric_time__martian_day | ||
, subq_11.ts AS metric_time__hour | ||
, SUM(subq_9.archived_users) AS subdaily_cumulative_window_metric | ||
FROM ***************************.mf_time_spine_hour subq_11 | ||
INNER JOIN ( | ||
-- Read Elements From Semantic Model 'users_ds_source' | ||
-- Metric Time Dimension 'archived_at' | ||
SELECT | ||
DATE_TRUNC('hour', archived_at) AS metric_time__hour | ||
, 1 AS archived_users | ||
FROM ***************************.dim_users users_ds_source_src_28000 | ||
) subq_9 | ||
ON | ||
( | ||
subq_9.metric_time__hour <= subq_11.ts | ||
) AND ( | ||
subq_9.metric_time__hour > DATEADD(hour, -3, subq_11.ts) | ||
) | ||
LEFT OUTER JOIN | ||
***************************.mf_time_spine subq_12 | ||
ON | ||
DATE_TRUNC('day', subq_11.ts) = subq_12.ds | ||
GROUP BY | ||
subq_12.martian_day | ||
, subq_11.ts |
464 changes: 464 additions & 0 deletions
464
...an/Databricks/test_multiple_time_spines_in_query_for_join_to_time_spine_metric__plan0.sql
Large diffs are not rendered by default.
Oops, something went wrong.
50 changes: 50 additions & 0 deletions
50
...cks/test_multiple_time_spines_in_query_for_join_to_time_spine_metric__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,50 @@ | ||
test_name: test_multiple_time_spines_in_query_for_join_to_time_spine_metric | ||
test_filename: test_custom_granularity.py | ||
sql_engine: Databricks | ||
--- | ||
-- Join to Time Spine Dataset | ||
-- Compute Metrics via Expressions | ||
SELECT | ||
subq_18.metric_time__martian_day AS metric_time__martian_day | ||
, subq_18.metric_time__hour AS metric_time__hour | ||
, subq_14.archived_users AS subdaily_join_to_time_spine_metric | ||
FROM ( | ||
-- Change Column Aliases | ||
-- Join to Custom Granularity Dataset | ||
-- Pass Only Elements: ['metric_time__martian_day', 'metric_time__hour'] | ||
SELECT | ||
subq_16.martian_day AS metric_time__martian_day | ||
, time_spine_src_28005.ts AS metric_time__hour | ||
FROM ***************************.mf_time_spine_hour time_spine_src_28005 | ||
LEFT OUTER JOIN | ||
***************************.mf_time_spine subq_16 | ||
ON | ||
DATE_TRUNC('day', time_spine_src_28005.ts) = subq_16.ds | ||
) subq_18 | ||
LEFT OUTER JOIN ( | ||
-- Metric Time Dimension 'archived_at' | ||
-- Join to Custom Granularity Dataset | ||
-- Pass Only Elements: ['archived_users', 'metric_time__martian_day', 'metric_time__hour'] | ||
-- Aggregate Measures | ||
SELECT | ||
subq_11.martian_day AS metric_time__martian_day | ||
, subq_10.archived_at__hour AS metric_time__hour | ||
, SUM(subq_10.archived_users) AS archived_users | ||
FROM ( | ||
-- Read Elements From Semantic Model 'users_ds_source' | ||
SELECT | ||
1 AS archived_users | ||
, DATE_TRUNC('hour', archived_at) AS archived_at__hour | ||
, DATE_TRUNC('day', archived_at) AS archived_at__day | ||
FROM ***************************.dim_users users_ds_source_src_28000 | ||
) subq_10 | ||
LEFT OUTER JOIN | ||
***************************.mf_time_spine subq_11 | ||
ON | ||
subq_10.archived_at__day = subq_11.ds | ||
GROUP BY | ||
subq_11.martian_day | ||
, subq_10.archived_at__hour | ||
) subq_14 | ||
ON | ||
subq_18.metric_time__hour = subq_14.metric_time__hour |
Oops, something went wrong.