Partitionierte Ereignisprotokolle, Stream Processing, Fenster, Watermarks und zustandsbehaftete Verarbeitung ermöglichen laufende Auswertungen. Verspätete und doppelte Ereignisse werden ausdrücklich behandelt.