kafka-ingest-concept/templates/create_mvs.sql

-- The number of clicks on the ad within one minute after the ad was shown.
create materialized view m_click_statistic as
select
    count(user_id) as clicks_count,
    ad_id
from
    ad_source
where
    click_timestamp is not null
    and impression_timestamp < click_timestamp
    and impression_timestamp + interval '1' minute >= click_timestamp
group by
    ad_id;

create materialized view clicks as
select
    user_id,
    ad_id,
    click_timestamp,
    impression_timestamp
from
    ad_source;