From 4774616008812b58be948bf19be1ae62f5d9f815 Mon Sep 17 00:00:00 2001 From: Mike Stepanovic Date: Fri, 7 Mar 2025 14:27:05 -0700 Subject: [PATCH] added sender to events and changes, moved clustering from changes to transactions --- models/gold/core/core__fact_changes.sql | 3 ++- models/gold/core/core__fact_events.sql | 1 + models/gold/core/core__fact_transactions.sql | 2 +- 3 files changed, 4 insertions(+), 2 deletions(-) diff --git a/models/gold/core/core__fact_changes.sql b/models/gold/core/core__fact_changes.sql index d1083cf..1a4db02 100644 --- a/models/gold/core/core__fact_changes.sql +++ b/models/gold/core/core__fact_changes.sql @@ -4,7 +4,7 @@ incremental_strategy = 'merge', incremental_predicates = ["dynamic_range_predicate","block_timestamp::DATE"], merge_exclude_columns = ["inserted_timestamp"], - cluster_by = ['block_timestamp::DATE','modified_timestamp::DATE'], + cluster_by = ['block_timestamp::DATE'], post_hook = "ALTER TABLE {{ this }} ADD SEARCH OPTIMIZATION ON EQUALITY(version,tx_hash,change_type,inner_change_type,change_address,change_module,change_resource,payload_function);", tags = ['core'] ) }} @@ -16,6 +16,7 @@ SELECT version, success, A.tx_type, + A.sender, A.payload_function, b.index AS change_index, b.value :data :data AS change_data, diff --git a/models/gold/core/core__fact_events.sql b/models/gold/core/core__fact_events.sql index 76848d3..3a1b306 100644 --- a/models/gold/core/core__fact_events.sql +++ b/models/gold/core/core__fact_events.sql @@ -16,6 +16,7 @@ SELECT version, success, A.tx_type, + A.sender, A.payload_function, b.index AS event_index, b.value :type :: STRING AS event_type, diff --git a/models/gold/core/core__fact_transactions.sql b/models/gold/core/core__fact_transactions.sql index 9e58502..1335f18 100644 --- a/models/gold/core/core__fact_transactions.sql +++ b/models/gold/core/core__fact_transactions.sql @@ -4,7 +4,7 @@ incremental_strategy = 'merge', incremental_predicates = ["dynamic_range_predicate", "block_timestamp::DATE"], merge_exclude_columns = ["inserted_timestamp"], - cluster_by = ['block_timestamp::DATE'], + cluster_by = ['block_timestamp::DATE','modified_timestamp::DATE'], post_hook = "ALTER TABLE {{ this }} ADD SEARCH OPTIMIZATION ON EQUALITY(version,tx_hash,payload_function,sender);", tags = ['core'] ) }}