From 8ba621e29daa8f92f6d66f599689a2b96e81a638 Mon Sep 17 00:00:00 2001 From: Lihan Li Date: Wed, 17 Aug 2022 14:28:08 +1000 Subject: [PATCH] Added partition and cluster support to BigQuery materialized view --- materialized-views/macros/bigquery/adapters.sql | 6 ++++++ 1 file changed, 6 insertions(+) diff --git a/materialized-views/macros/bigquery/adapters.sql b/materialized-views/macros/bigquery/adapters.sql index ed12352..b2ad3e1 100644 --- a/materialized-views/macros/bigquery/adapters.sql +++ b/materialized-views/macros/bigquery/adapters.sql @@ -14,9 +14,15 @@ {%- set refresh_interval_minutes = config.get('refresh_interval_minutes', none) -%} {%- set sql_header = config.get('sql_header', none) -%} + {%- set raw_partition_by = config.get('partition_by', none) -%} + {%- set partition_config = adapter.parse_partition_by(raw_partition_by) -%} + {%- set raw_cluster_by = config.get('cluster_by', none) -%} + {{ sql_header if sql_header is not none }} create materialized view {{relation}} + {{ partition_by(partition_config) }} + {{ cluster_by(raw_cluster_by) }} {{ dbt_labs_materialized_views.bigquery_options( enable_refresh=enable_refresh, refresh_interval_minutes=refresh_interval_minutes