Schema splitter-aggregator

Lo Schema splitter-aggregator offre un approccio formale per instradare record da fonti multiple verso rami paralleli secondo regole predefinite e quindi produrre metriche consolidate per ramo e finestra. Concettualmente, i record attraversano uno splitter che valuta predicati o valori di campo e assegna ogni record a un gruppo. Ogni gruppo mantiene un’aggregazione indipendente, come somma, media o massimo, su una finestra configurata. Il design supporta dati in ritardo, deduplicazione e allineamento tra stream per garantire statistiche coerenti tra fonti. Ciò consente di costruire dashboard in tempo reale o report batch da fonti eterogenee. Il valore principale risiede nel separare la logica di routing da quella di aggregazione, permettendo una calibrazione indipendente della suddivisione e del calcolo delle metriche, offrendo uno schema di output unificato per confronti su gruppi o finestre temporali. Casi d’uso includono reti di sensori con più feed, analisi di log multi-sorgente e correlazione di eventi tra sistemi. Si distingue per configurazioni esplicite delle finestre, deduplicazione integrata e connettori opzionali alle piattaforme di streaming, offrendo risultati deterministici anche se le sorgenti emettono dati in ordine non ottimale o con latenza variabile. Supporta politiche di aggregazione comuni (somma, conteggio, media, min, max) e consente espressioni personalizzate per metriche complesse.