blob: c1b9be010f1bcb087c03329d496975567816e953 [file] [log] [blame]
-- NOTE: Join Operator is currently not fully stable,
-- we are actively working on stabilizing it.
-- Enrich PageViewEvent with member profile data
INSERT INTO kafka.tracking.EnrichedPageVIewEvent
SELECT *
FROM Kafka.PageViewEvent as pv
JOIN Kafka.ProfileChanges.`$table` as p
ON pv.memberid = p.memberid
-- You can add additional SQL statements here