Spark/Flink job for windowed CTR aggregation
What should a stream job look like that calculates CTR by campaign_id and time windows?
Answer as you would in an interview
Answer aloud or write down a few key points. The text field is optional; the review opens after your attempt.