Splittring-aggregator-mönster

Splittrings- och aggregatormönstret erbjuder ett formellt tillvägagångssätt för att dirigera register från flera källor till parallella grenar enligt definierade regler och sedan producera sammanställda mätvärden per gren och fönster. Designen bibehåller en oberoende sammanställning per grupp, såsom summa, medelvärde och max över ett konfigurerat fönster. Systemet hanterar försenade data, deduplicering och synkronisering över strömmar för att säkerställa konsekventa statistik över källor. Användningsfall inkluderar sensornätverk med flera feeds, multi-källa logghantering och kors-system händelse-sammanlänkning. Värdet ligger i separationen mellan routing och aggregationslogik, med möjlighet att finjustera varje del oberoende och konnektorer till streaming-plattformar som garanterar deterministiska resultat även när källor skickar data i olika ordning eller med varierande latens. Stödjer standard-aggregationspolicys (summa, räknare, medelvärde, min, max) och tillåter anpassade uttryck för komplexa mätetal.