Late Event — event-time oynasi uchun watermark o‘tib ketganidan keyin kelgan event. U cache, distributed snapshot yoki stream-processing tizimlaridagi muayyan data va vaqt semantikasini ifodalaydi. Aniq kafolatlar platforma, protocol hamda konfiguratsiyaga bog‘liq; termin nomi barcha implementatsiyada bir xil xulqni anglatmaydi.
Tizimdagi vazifasi
Distributed source, mobile offline holati yoki retry sabab event kechikadi. Allowed lateness ichida operator oynani yangilashi va yangi natija chiqarishi mumkin; undan keyin event side outputga yoki dropga ketadi.
Late Event alohida feature emas, source, storage, tarmoq va consumer xulqi bilan birga ishlaydi. Request qabul qilinishi, state durable bo‘lishi va natijaning tashqi tizimda ko‘rinishi turli nuqtalar bo‘lishi mumkin. Shu chegaralar hujjatlashtirilsa retry va recoverydagi noaniqlik kamayadi.
Holat o‘zgarishi
Late event out-of-order eventning maxsus holati: tartibi o‘zgargan har event kechikkan hisoblanmaydi. Watermark tizim bundan oldingi eventlar endi kam keladi degan taxmindir.
Late Event kafolati butun pipeline bo‘yicha baholanadi. Source timestamp to‘g‘ri bo‘lsa ham broker, operator, cache va sink boshqa ordering yoki durability semantikasini berishi mumkin. Har acknowledgement qaysi state durable va visible bo‘lganini ifodalaydi.
Ishonchlilik
Drop rate kuzatiladi, chunki juda agressiv watermark data yo‘qotadi, juda konservativi state va latencyni oshiradi. Downstream correction va retraction semantikasi aniq bo‘ladi.
Late Event bilan ishlovchi client retry uchun umumiy deadline, exponential backoff va jitter qo‘llaydi. Cheksiz retry backendni himoya qilmaydi. Side effect bo‘lsa idempotency key yoki checkpoint bilan duplicate effect cheklanadi; timeout operatsiya bajarilmadi degani emas.
Late Event dizaynida correctness, freshness, latency va resource sarfi birga tanlanadi. Past latency uchun cache yoki early firing ishlatilsa stale yoki preliminary natija ehtimoli paydo bo‘ladi. Qat’iyroq ordering va completeness ko‘proq buffer, coordination yoki kutish vaqtini talab qiladi.
Kuzatuv
Late Event uchun monitoring semantic metrikalarni qamrab oladi: hit ratio, stale age, watermark lag, late count, compaction backlog yoki offset distance. Process up signali correctnessni ko‘rsatmaydi. Alert aniq key, partition va vaqt oralig‘ini tekshirish qadamiga bog‘lanadi.
Late Event optimallashtirilganda correctness testi qayta bajariladi. Batching, local cache, asynchronous flush yoki parallelism throughputni oshirishi mumkin, ammo ordering va freshnessni o‘zgartiradi. Feature flag bilan yoqilgan yo‘l ham shu semantic testdan o‘tadi.
Late Event ko‘p tenantli muhitda adolatli resource taqsimotini talab qiladi. Bitta tenantning hot keylari, katta oynasi yoki sekin consumeri umumiy memory va diskni egallamasligi uchun per-tenant limit hamda isolation ishlatiladi. Limitga yetish correctnessni buzadigan yashirin drop emas, o‘lchanadigan va tushunarli javob bilan namoyon bo‘ladi.
Late Eventga bog‘liq default qiymatlar environmentlar orasida bir xil deb taxmin qilinmaydi. Developmentdagi kichik data va bitta node productiondagi parallelizm, retention hamda failure xulqini to‘liq takrorlamaydi.
Late Event uchun qabul mezoni misol bilan tasdiqlanadi: bir xil input va boshlang‘ich state berilganda kutilgan output, metadata hamda tashqi effect birgalikda tekshiriladi. Faqat yakuniy qiymatni solishtirish oraliq yo‘qotish yoki takroriy yozuvni yashirishi mumkin.
Late Event bo‘yicha o‘zgarishdan keyin faqat muvaffaqiyatli oqim emas, miss, timeout, duplicate, late data, restart va partial failure holati ham tekshiriladi. Qabul qilingan cheklovlar hujjatlashtiriladi va boshqa workloadga avtomatik ko‘chirilmaydi.
Bog‘liq tushunchalar
watermark, event time, allowed lateness, out-of-order event, side output, window update