feat(DENG-4847): Add profile_group_id to telemetry_derived.clients_daily_scalar_aggregates_v1 (#6207)
* DENG-4847 update test schema json for main_v5 to include profile_group_id * DENG-4847 add profile_group_id to clients_daily_scalar_aggregates_v1
This commit is contained in:
Родитель
53f385510c
Коммит
3bd53ce175
|
@ -96,7 +96,10 @@ def generate_sql(
|
|||
app_version,
|
||||
app_build_id,
|
||||
channel,
|
||||
{aggregates}
|
||||
{aggregates},
|
||||
mozfun.stats.mode_last(
|
||||
ARRAY_AGG(profile_group_id ORDER BY submission_timestamp)
|
||||
) AS profile_group_id,
|
||||
FROM sampled_data
|
||||
GROUP BY
|
||||
submission_date,
|
||||
|
|
|
@ -12920,7 +12920,10 @@ aggregated AS (
|
|||
'true',
|
||||
SUM(CASE WHEN payload.processes.parent.scalars.widget_dark_mode = TRUE THEN 1 ELSE 0 END)
|
||||
)
|
||||
] AS scalar_aggregates
|
||||
] AS scalar_aggregates,
|
||||
mozfun.stats.mode_last(
|
||||
ARRAY_AGG(profile_group_id ORDER BY submission_timestamp)
|
||||
) AS profile_group_id,
|
||||
FROM
|
||||
sampled_data
|
||||
GROUP BY
|
||||
|
|
|
@ -42,3 +42,6 @@ fields:
|
|||
mode: REPEATED
|
||||
name: scalar_aggregates
|
||||
type: RECORD
|
||||
- mode: NULLABLE
|
||||
name: profile_group_id
|
||||
type: STRING
|
||||
|
|
|
@ -1631,5 +1631,10 @@
|
|||
"mode": "NULLABLE",
|
||||
"name": "payload",
|
||||
"type": "RECORD"
|
||||
},
|
||||
{
|
||||
"mode": "NULLABLE",
|
||||
"name": "profile_group_id",
|
||||
"type": "STRING"
|
||||
}
|
||||
]
|
||||
|
|
Загрузка…
Ссылка в новой задаче