•KSQL enables easy transformations of data within the pipe. •Transforming data while moving from Kafka to another system. CREATE STREAM vip_actions AS
SELECT userid, page, action FROM clickstream c LEFT JOIN users u ON c.userid = u.user_id
WHERE u.level = 'Platinum';