Sanntidsbehandling

Sanntidsbehandling håndterer innkommende hendelser løpende mot et latensmål fastsatt for applikasjonen. I stedet for å vente på en komplett batch reagerer applikasjonen på en datastrøm. Ordet «sanntid» angir ikke i seg selv en fast millisekundgrense eller en garantert maksimal responstid.

I et fiktivt eksempel teller et dashbord fullførte eksportjobber per minutt. Fullføringshendelsen for J-31 oppstår klokken 10:04, men når behandlingen først klokken 10:07. Begge tidspunktene bruker samme tidssone. En beregning etter hendelsestid plasserer den i minuttet 10:04; en beregning etter behandlingstid i minuttet 10:07. De besvarer ulike spørsmål.

Samordne rask visning og fullstendige resultater

Teller visningen etter hendelsestid, trengs en regel for forsinkede meldinger: Skal en allerede vist minuttverdi korrigeres, eller skal den forsinkede hendelsen registreres separat? Lengre venting kan få med flere forsinkede hendelser, men utsetter resultatet. Et watermark markerer den antatte fremdriften i hendelsestiden. Hendelser med tidligere tidsstempler kan fortsatt komme etterpå.

Fastsett hvor latensmålingen begynner og slutter, hvor gammel den eldste ventende oppføringen er, og hvordan etterslep blir synlig. Tidsstempler og klokkesynkronisering hører også til pålitelig tidsplassering. Et dashbord som oppdateres regelmessig, beviser ikke i seg selv at alle de underliggende hendelsene allerede er ferdigbehandlet.

Kilder

• Apache Flink — Timely Stream Processing