select record_schema,
data_channel,
record_count
from (
select 'amdp' as record_schema,
'AQFERCONVERSIONS' as data_channel,
sum(cardinality(conversions)) as record_count,
event_date
from aqfer.collation_hourly_v5_1
group by event_date
union
select 'amdp' as record_schema,
'AQFERGEOEVENTS' as data_channel,
sum(cardinality(geo_events)) as record_count,
event_date
from aqfer.collation_hourly_v5_1
group by event_date
union
select 'amdp' as record_schema,
'AQFERVIEWS' as data_channel,
count(view) as record_count,
event_date
from aqfer.collation_hourly_v5_1
cross join unnest("collation_hourly_v5_1".views) as t(view)
where view.has_interaction = False
group by event_date
union
select 'amdp' as record_schema,
'AQFERINTERACTIONS' as data_channel,
sum(cardinality(view.interaction)) as record_count,
event_date
from aqfer.collation_hourly_v5_1
cross join unnest("collation_hourly_v5_1".views) as t(view)
group by event_date
union
select 'amdp' as record_schema,
'AQFERIMPRESSIONS' as data_channel,
count(imp) as record_count,
event_date
from aqfer.collation_hourly_v5_1
cross join unnest("collation_hourly_v5_1".impressions) as t(imp)
where imp.has_click = False
and cardinality(imp.engagements) = 0
group by event_date
union
select 'amdp' as record_schema,
'AQFERCLICKS' as data_channel,
sum(cardinality(imp.clicks)) as record_count,
event_date
from aqfer.collation_hourly_v5_1
cross join unnest("collation_hourly_v5_1".impressions) as t(imp)
group by event_date
UNION
select 'amdp' as record_schema,
'AQFERENGAGEMENTS' as data_channel,
sum(cardinality(imp.engagements)) as record_count,
event_date
from aqfer.collation_hourly_v5_1
cross join unnest("collation_hourly_v5_1".impressions) as t(imp)
group by event_date
union
select 'amdp' as record_schema,
'AQFERPOIVISITS' as data_channel,
sum(cardinality(poi_visits)) as record_count,
event_date
from aqfer.collation_hourly_v5_1
group by event_date
union
select 'amdp' as record_schema,
'AQFEROTHEREVENTS' as data_channel,
sum(cardinality(other_event)) as record_count,
event_date
from aqfer.collation_hourly_v5_1
group by event_date
union
select 'amdp' as record_schema,
'AQFERIDSYNCS' as data_channel,
sum(cardinality(id_syncs)) as record_count,
event_date
from aqfer.collation_hourly_v5_1
group by event_date
union
select 'amdp' as record_schema,
'AQFERTEXTCLICKS' as data_channel,
sum(cardinality(text_clicks)) as record_count,
event_date
from aqfer.collation_hourly_v5_1
group by event_date
)
where record_count > 0
and event_date = '{{env "PREV_DATE"}}';