Skip to content

Commit 115e15a

Browse files
authored
feat(events_stream): Add document_event_number column to events_stream_v1 tables and event_id column to events_stream views (DENG-9800) (#8596)
* feat(events_stream): Add `document_event_number` column to `events_stream_v1` tables (DENG-9800). * feat(events_stream): Add `event_id` column to `events_stream` views.
1 parent bade223 commit 115e15a

File tree

3 files changed

+4
-0
lines changed

3 files changed

+4
-0
lines changed

sql_generators/glean_usage/templates/cross_channel_events_stream.query.sql

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -20,6 +20,7 @@ WITH events_stream_union AS (
2020
{% endfor %}
2121
)
2222
SELECT
23+
CONCAT(document_id, '-', document_event_number) AS event_id,
2324
*,
2425
{% if extras_by_type %}
2526
{{ event_extras_by_type_struct(extras_by_type) }} AS extras

sql_generators/glean_usage/templates/events_stream.view.sql

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -5,6 +5,7 @@ CREATE OR REPLACE VIEW
55
`{{ project_id }}.{{ events_stream_view }}`
66
AS
77
SELECT
8+
CONCAT(document_id, '-', document_event_number) AS event_id,
89
*,
910
{% if extras_by_type %}
1011
{{ event_extras_by_type_struct(extras_by_type) }} AS extras

sql_generators/glean_usage/templates/events_stream_v1.query.sql

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -135,10 +135,12 @@ SELECT
135135
event.name AS event_name,
136136
ARRAY_TO_STRING([event.category, event.name], '.') AS event, -- handles NULL values better
137137
from_map_event_extra(event.extra) AS event_extra,
138+
(event_offset + 1) AS document_event_number,
138139
FROM
139140
base
140141
CROSS JOIN
141142
UNNEST(events) AS event
143+
WITH OFFSET AS event_offset
142144
{% if app_name == "firefox_desktop" %}
143145
WHERE
144146
-- See https://mozilla-hub.atlassian.net/browse/DENG-7513

0 commit comments

Comments
 (0)