• Challenges in stream processing.
  • Handle late data: watermarks, triggers, accumulation.